You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by xi...@apache.org on 2017/11/29 19:36:47 UTC
[8/8] samza git commit: Merge branch 'master' into 0.14.0
Merge branch 'master' into 0.14.0
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/04ee7fee
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/04ee7fee
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/04ee7fee
Branch: refs/heads/0.14.0
Commit: 04ee7fee60a79e073e634d08ba5be881376e1bd0
Parents: fae73b2 12e61e9
Author: xiliu <xi...@xiliu-ld1.linkedin.biz>
Authored: Wed Nov 29 11:35:37 2017 -0800
Committer: xiliu <xi...@xiliu-ld1.linkedin.biz>
Committed: Wed Nov 29 11:35:37 2017 -0800
----------------------------------------------------------------------
build.gradle | 55 +++-
.../versioned/yarn/yarn-host-affinity.md | 2 +-
.../versioned/hello-samza-high-level-code.md | 87 +++---
docs/startup/preview/index.md | 67 +++--
.../kinesis/KinesisAWSCredentialsProvider.java | 69 +++++
.../samza/system/kinesis/KinesisConfig.java | 287 ++++++++++++++++++
.../system/kinesis/KinesisSystemAdmin.java | 124 ++++++++
.../system/kinesis/KinesisSystemFactory.java | 87 ++++++
.../KinesisIncomingMessageEnvelope.java | 62 ++++
.../consumer/KinesisRecordProcessor.java | 208 +++++++++++++
.../KinesisRecordProcessorListener.java | 51 ++++
.../kinesis/consumer/KinesisSystemConsumer.java | 256 ++++++++++++++++
.../consumer/KinesisSystemConsumerOffset.java | 107 +++++++
.../consumer/NoAvailablePartitionException.java | 38 +++
.../system/kinesis/consumer/SSPAllocator.java | 73 +++++
.../metrics/KinesisSystemConsumerMetrics.java | 106 +++++++
.../system/kinesis/metrics/SamzaHistogram.java | 63 ++++
.../TestKinesisAWSCredentialsProvider.java | 60 ++++
.../samza/system/kinesis/TestKinesisConfig.java | 132 ++++++++
.../kinesis/TestKinesisSystemFactory.java | 115 +++++++
.../consumer/TestKinesisRecordProcessor.java | 301 +++++++++++++++++++
.../consumer/TestKinesisSystemConsumer.java | 270 +++++++++++++++++
.../TestKinesisSystemConsumerOffset.java | 48 +++
.../kinesis/consumer/TestSSPAllocator.java | 127 ++++++++
.../apache/samza/config/JavaStorageConfig.java | 5 +-
.../samza/operators/impl/OperatorImplGraph.java | 14 +-
.../operators/impl/PartitionByOperatorImpl.java | 3 +-
.../samza/config/TestJavaStorageConfig.java | 13 +
settings.gradle | 5 +-
29 files changed, 2740 insertions(+), 95 deletions(-)
----------------------------------------------------------------------