Closes #1299
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3e84a5f3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3e84a5f3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3e84a5f3 Branch: refs/heads/master Commit: 3e84a5f3c35a64de5e7be642ff3b7b4dcfd541b0 Parents: 9b47228 367fcac Author: Dan Halperin <[email protected]> Authored: Mon Nov 7 13:33:05 2016 -0800 Committer: Dan Halperin <[email protected]> Committed: Mon Nov 7 13:33:05 2016 -0800 ---------------------------------------------------------------------- sdks/java/io/kinesis/pom.xml | 21 ++++++-------------- .../beam/sdk/io/kinesis/CustomOptional.java | 21 ++++++++++++++++---- .../beam/sdk/io/kinesis/KinesisRecord.java | 3 +-- .../beam/sdk/io/kinesis/CustomOptionalTest.java | 10 ++++++++++ 4 files changed, 34 insertions(+), 21 deletions(-) ----------------------------------------------------------------------
