Re: Review Request 66614: HIVE-19210: Create separate module for streaming ingest
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/66614/ --- (Updated April 13, 2018, 11:58 p.m.) Review request for hive, Ashutosh Chauhan and EugeneBK EugeneBK. Changes --- Not moving mutate package from hcat. Bugs: HIVE-19210 https://issues.apache.org/jira/browse/HIVE-19210 Repository: hive-git Description --- HIVE-19210: Create separate module for streaming ingest Diffs (updated) - hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/package-info.java PRE-CREATION pom.xml 5802bd3 streaming/pom.xml PRE-CREATION streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ConnectionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/DelimitedInputWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HeartBeatFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HiveEndPoint.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ImpersonationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidColumn.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidPartition.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTrasactionState.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/PartitionCreationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/QueryFailedException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/RecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/SerializationError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingConnection.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingIOFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictJsonWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictRegexWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatch.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatchUnAvailable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/package.html PRE-CREATION streaming/src/test/org/apache/hive/streaming/TestDelimitedInputWriter.java PRE-CREATION streaming/src/test/org/apache/hive/streaming/TestStreaming.java PRE-CREATION Diff: https://reviews.apache.org/r/66614/diff/2/ Changes: https://reviews.apache.org/r/66614/diff/1-2/ Testing --- Thanks, Prasanth_J
Re: Review Request 66614: HIVE-19210: Create separate module for streaming ingest
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/66614/ --- (Updated April 13, 2018, 10:49 p.m.) Review request for hive, Ashutosh Chauhan and EugeneBK EugeneBK. Bugs: HIVE-19210 https://issues.apache.org/jira/browse/HIVE-19210 Repository: hive-git Description --- HIVE-19210: Create separate module for streaming ingest Diffs - hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/package-info.java PRE-CREATION pom.xml 5802bd3a354ce6a78fd786e43847c7475a3f965e streaming/pom.xml PRE-CREATION streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ConnectionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/DelimitedInputWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HeartBeatFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HiveEndPoint.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ImpersonationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidColumn.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidPartition.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTrasactionState.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/PartitionCreationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/QueryFailedException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/RecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/SerializationError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingConnection.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingIOFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingUtil.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictJsonWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictRegexWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatch.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatchUnAvailable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/HiveConfFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/UgiMetaStoreClientFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/AcidTable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/AcidTableSerializer.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/ClientException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/ConnectionException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/MutatorClient.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/MutatorClientBuilder.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/TableType.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/Transaction.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/TransactionException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/HeartbeatFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/HeartbeatTimerTask.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/Lock.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/LockException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/LockFailureListener.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/doc-files/system-overview.dot PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/package.html PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdResolver.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdResolverImpl.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/GroupRevisitedException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/GroupingValidator.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/MetaStorePartitio
Review Request 66614: HIVE-19210: Create separate module for streaming ingest
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/66614/ --- Review request for hive, Ashutosh Chauhan and EugeneBK EugeneBK. Repository: hive-git Description --- HIVE-19210: Create separate module for streaming ingest Diffs - hcatalog/streaming/src/java/org/apache/hive/hcatalog/streaming/package-info.java PRE-CREATION pom.xml 5802bd3a354ce6a78fd786e43847c7475a3f965e streaming/pom.xml PRE-CREATION streaming/src/java/org/apache/hive/streaming/AbstractRecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ConnectionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/DelimitedInputWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HeartBeatFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/HiveEndPoint.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/ImpersonationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidColumn.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidPartition.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/InvalidTrasactionState.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/PartitionCreationFailed.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/QueryFailedException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/RecordWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/SerializationError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingConnection.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingIOFailure.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StreamingUtil.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictJsonWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/StrictRegexWriter.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatch.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionBatchUnAvailable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/TransactionError.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/HiveConfFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/UgiMetaStoreClientFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/AcidTable.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/AcidTableSerializer.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/ClientException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/ConnectionException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/MutatorClient.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/MutatorClientBuilder.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/TableType.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/Transaction.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/TransactionException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/HeartbeatFactory.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/HeartbeatTimerTask.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/Lock.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/LockException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/client/lock/LockFailureListener.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/doc-files/system-overview.dot PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/package.html PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdResolver.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/BucketIdResolverImpl.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/GroupRevisitedException.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/GroupingValidator.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/MetaStorePartitionHelper.java PRE-CREATION streaming/src/java/org/apache/hive/streaming/mutate/worker/Mutator.java PRE-CREA