streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/AbstractPipelineElementResource.java (2 lines): - line 113: //TODO remove this and find a better solution - line 115: // TODO remove after full internationalization support has been implemented streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/TransformOutputSchemaGenerator.java (2 lines): - line 62: // TODO exceptions - line 149: // TODO check support for lists and nested properties streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionProcessor.java (2 lines): - line 60: //TODO: Change Icon - line 99: //TODO: Better handling of multiple timestamps (if the field "change_detected" is already in the input)? streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/StatementHandler.java (2 lines): - line 129: //TODO: Possible error: when the event does not contain all objects of the parameter list - line 138: //TODO: start the for loop all over again streampipes-client-python/streampipes/functions/broker/broker_handler.py (2 lines): - line 36: # TODO Exception should be removed once all brokers are implemented. - line 46: ) -> Broker: # TODO implementation for more transport_protocols streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntime.java (2 lines): - line 127: * TODO Add also jms support - line 223: // TODO find a better solution streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/redis/RedisSink.java (2 lines): - line 81: // TODO: Use this after optional parameters implementation - line 100: // TODO: Use this after optional parameters implementation ui/src/app/connect/services/transformation-rule.service.ts (1 line): - line 619: // TODO: better solution to check if the mode is valid streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/InvocablePipelineElementResource.java (1 line): - line 159: // TODO move endpoint to /elementId/instances/runningInstanceId streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/ListOutputSchemaGenerator.java (1 line): - line 57: // TODO SIP08 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationProcessor.java (1 line): - line 58: //TODO: Change Icon streampipes-messaging-mqtt/src/main/java/org/apache/streampipes/messaging/mqtt/MqttPublisher.java (1 line): - line 54: // TODO exception handling once system-wide logging is implemented streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/UserGroupResource.java (1 line): - line 79: // TODO remove group from all users streampipes-model/src/main/java/org/apache/streampipes/model/runtime/Event.java (1 line): - line 83: // TODO this currently only works for first-level properties ui/src/app/editor/services/jsplumb-bridge.service.ts (1 line): - line 126: // TODO: Overloading Functions? streampipes-client-python/streampipes/functions/utils/data_stream_generator.py (1 line): - line 52: # TODO Use an more general approach to create a data stream streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/AbstractParameterExtractor.java (1 line): - line 375: // TODO exceptions streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/helper/buffer/SpBufferBuilder.java (1 line): - line 117: // TODO: Logger Info streampipes-commons/src/main/java/org/apache/streampipes/commons/zip/ZipFileExtractor.java (1 line): - line 38: // TODO used by export feature - extend this to support binaries streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataProcessorVerifier.java (1 line): - line 34: // TODO Auto-generated constructor stub streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/Sequence.java (1 line): - line 41: // TODO: add RuntimeContext streampipes-wrapper-distributed/src/main/java/org/apache/streampipes/wrapper/distributed/runtime/DistributedRuntime.java (1 line): - line 100: // TODO add also jms support streampipes-model/src/main/java/org/apache/streampipes/model/datalake/CustomMapSerializer.java (1 line): - line 28: /* TODO This is a really ugly hack to properly serialize custom configuration maps streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessor.java (1 line): - line 91: //TODO: Test, if eventProperty is a primitive type (string, number, ...) streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/RunningInstances.java (1 line): - line 69: // TODO change this to appId for STREAMPIPES-319 streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/page/WelcomePageGenerator.java (1 line): - line 96: // TODO remove after full internationalization support has been implemented streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/InputStreamNameGenerator.java (1 line): - line 37: // TODO why is the prefix not in the parameters.getInEventType streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/couchdb/CouchDbSink.java (1 line): - line 73: //TODO: Use this after optional parameters implementation ui/projects/streampipes/shared-ui/src/lib/dialog/data-download-dialog/components/download/download.component.ts (1 line): - line 54: // TODO implement streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/SpKafkaProducer.java (1 line): - line 66: // TODO backwards compatibility, remove later streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java (1 line): - line 75: // TODO change access token to an optional parameter streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/manager/ProtocolManager.java (1 line): - line 38: // TODO currently only the topic name is used as an identifier for a consumer/producer. Should streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemaps/GoogleMapsGeocoderProcessor.java (1 line): - line 91: // TODO: RequestDeniedException streampipes-client-python/streampipes/functions/registration.py (1 line): - line 48: self.functions.append(streampipes_function) # TODO register function to AdminAPI streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/PropertyDuplicateRemover.java (1 line): - line 52: //TODO: hack streampipes-model/src/main/java/org/apache/streampipes/model/runtime/EventFactory.java (1 line): - line 59: // TODO provide output event schema through RuntimeContext streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/JdbcClient.java (1 line): - line 197: //TODO: Add batch support (https://stackoverflow.com/questions/3784197/efficient-way-to-do-batch-inserts-with-jdbc) streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/PipelineCanvasMetadataStorageImpl.java (1 line): - line 50: // TODO add CouchDB view streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/info/VersionInfoProvider.java (1 line): - line 28: // TODO add versions of other services archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Program.java (1 line): - line 63: // TODO add logic here streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/ElasticSearchController.java (1 line): - line 61: //TODO after refactoring streampipes-connect-shared/src/main/java/org/apache/streampipes/connect/shared/preprocessing/transform/value/TimestampTransformationRule.java (1 line): - line 82: //TODO how to handle exception?