You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/11/27 09:48:16 UTC
[09/50] samza git commit: Merge branch 'master' of
https://github.com/apache/samza
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 <jv...@linkedin.com>
Authored: Thu Oct 18 18:34:32 2018 -0700
Committer: Jagadish <jv...@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(-)
----------------------------------------------------------------------