Merge branch 'master' of https://github.com/apache/samza
Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/19ededcc Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/19ededcc Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/19ededcc Branch: refs/heads/master Commit: 19ededccf562bc100be7fedd4fbc6a30c13e9cbe Parents: b729f29 ba0b262 Author: Jagadish <jvenkatra...@linkedin.com> Authored: Thu Oct 18 18:34:32 2018 -0700 Committer: Jagadish <jvenkatra...@linkedin.com> Committed: Thu Oct 18 18:34:32 2018 -0700 ---------------------------------------------------------------------- .../documentation/versioned/connectors/kafka.md | 2 +- .../samza/application/SamzaApplication.java | 24 +- .../samza/application/StreamApplication.java | 67 +- .../samza/application/TaskApplication.java | 70 +-- .../descriptors/ApplicationDescriptor.java | 61 +- .../StreamApplicationDescriptor.java | 11 +- .../descriptors/TaskApplicationDescriptor.java | 34 +- .../context/ApplicationContainerContext.java | 36 +- .../ApplicationContainerContextFactory.java | 25 +- .../samza/context/ApplicationTaskContext.java | 32 +- .../context/ApplicationTaskContextFactory.java | 30 +- .../apache/samza/context/ContainerContext.java | 21 +- .../java/org/apache/samza/context/Context.java | 56 +- .../org/apache/samza/context/JobContext.java | 20 +- .../org/apache/samza/context/TaskContext.java | 53 +- .../descriptors/GenericInputDescriptor.java | 14 +- .../descriptors/GenericOutputDescriptor.java | 14 +- .../descriptors/GenericSystemDescriptor.java | 13 +- .../system/descriptors/InputDescriptor.java | 8 +- .../system/descriptors/OutputDescriptor.java | 8 +- .../system/descriptors/StreamDescriptor.java | 9 +- .../system/descriptors/SystemDescriptor.java | 9 +- .../main/java/org/apache/samza/table/Table.java | 21 +- .../samza/table/TableDescriptorsProvider.java | 98 --- .../table/descriptors/TableDescriptor.java | 37 +- .../java/org/apache/samza/task/TaskFactory.java | 4 +- .../descriptors/EventHubsInputDescriptor.java | 7 +- .../descriptors/EventHubsOutputDescriptor.java | 8 +- .../descriptors/EventHubsSystemDescriptor.java | 7 +- .../application/LegacyTaskApplication.java | 4 +- .../TaskApplicationDescriptorImpl.java | 12 +- .../org/apache/samza/execution/JobPlanner.java | 18 +- .../apache/samza/processor/StreamProcessor.java | 14 +- .../application/MockStreamApplication.java | 2 +- .../samza/application/TestApplicationUtil.java | 2 +- .../TestTaskApplicationDescriptorImpl.java | 10 +- .../execution/ExecutionPlannerTestBase.java | 12 +- .../samza/execution/TestExecutionPlanner.java | 2 +- .../TestJobNodeConfigurationGenerator.java | 4 +- .../kafka/descriptors/KafkaInputDescriptor.java | 8 +- .../descriptors/KafkaOutputDescriptor.java | 8 +- .../descriptors/KafkaSystemDescriptor.java | 7 +- .../system/kafka_deprecated/BrokerProxy.scala | 332 ++++++++++ .../DefaultFetchSimpleConsumer.scala | 66 ++ .../system/kafka_deprecated/GetOffset.scala | 116 ++++ .../kafka_deprecated/KafkaSystemAdmin.scala | 609 +++++++++++++++++++ .../kafka_deprecated/KafkaSystemConsumer.scala | 309 ++++++++++ .../KafkaSystemConsumerMetrics.scala | 100 +++ .../kafka_deprecated/KafkaSystemFactory.scala | 178 ++++++ .../kafka_deprecated/KafkaSystemProducer.scala | 235 +++++++ .../KafkaSystemProducerMetrics.scala | 42 ++ .../system/kafka_deprecated/MessageSink.scala | 35 ++ .../kafka_deprecated/TopicMetadataCache.scala | 78 +++ .../samza/system/kafka_deprecated/Toss.scala | 28 + .../samza/sql/interfaces/DslConverter.java | 1 + .../interfaces/SamzaSqlJavaTypeFactoryImpl.java | 8 +- .../samza/sql/runner/SamzaSqlApplication.java | 14 +- .../example/AppWithGlobalConfigExample.java | 8 +- .../apache/samza/example/BroadcastExample.java | 10 +- .../samza/example/KeyValueStoreExample.java | 8 +- .../org/apache/samza/example/MergeExample.java | 6 +- .../samza/example/OrderShipmentJoinExample.java | 8 +- .../samza/example/PageViewCounterExample.java | 6 +- .../samza/example/RepartitionExample.java | 8 +- .../samza/example/TaskApplicationExample.java | 12 +- .../org/apache/samza/example/WindowExample.java | 6 +- .../TestStandaloneIntegrationApplication.java | 6 +- .../EndOfStreamIntegrationTest.java | 4 +- .../WatermarkIntegrationTest.java | 4 +- .../test/framework/BroadcastAssertApp.java | 6 +- .../test/framework/FaultInjectionTest.java | 9 +- .../StreamApplicationIntegrationTest.java | 18 +- .../framework/StreamTaskIntegrationTest.java | 15 +- .../samza/test/framework/TestSchedulingApp.java | 4 +- .../test/operator/RepartitionJoinWindowApp.java | 8 +- .../test/operator/RepartitionWindowApp.java | 6 +- .../samza/test/operator/SessionWindowApp.java | 6 +- .../samza/test/operator/TumblingWindowApp.java | 6 +- .../test/processor/TestStreamApplication.java | 6 +- .../apache/samza/test/table/TestLocalTable.java | 9 +- .../table/TestLocalTableWithSideInputs.java | 8 +- .../table/TestTableDescriptorsProvider.java | 172 ------ 82 files changed, 2711 insertions(+), 701 deletions(-) ----------------------------------------------------------------------