-----------------------------------------------------------
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/MetaStorePartitionHelper.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/Mutator.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/MutatorCoordinator.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/MutatorCoordinatorBuilder.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/MutatorFactory.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/MutatorImpl.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/OperationType.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/PartitionCreationException.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/PartitionHelper.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/RecordInspector.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/RecordInspectorImpl.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/RecordSequenceException.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/SequenceValidator.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/WarehousePartitionHelper.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/mutate/worker/WorkerException.java
PRE-CREATION
streaming/src/java/org/apache/hive/streaming/package.html PRE-CREATION
streaming/src/test/org/apache/hive/streaming/StreamingIntegrationTester.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/TestDelimitedInputWriter.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/TestStreaming.java PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/ExampleUseCase.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/MutableRecord.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/ReflectiveMutatorFactory.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/StreamingAssert.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/StreamingTestUtils.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/TestMutations.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/client/TestAcidTableSerializer.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/client/TestMutatorClient.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/client/TestTransaction.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/client/lock/TestHeartbeatTimerTask.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/client/lock/TestLock.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestBucketIdResolverImpl.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestGroupingValidator.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestMetaStorePartitionHelper.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestMutatorCoordinator.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestMutatorImpl.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestRecordInspectorImpl.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestSequenceValidator.java
PRE-CREATION
streaming/src/test/org/apache/hive/streaming/mutate/worker/TestWarehousePartitionHelper.java
PRE-CREATION
streaming/src/test/sit PRE-CREATION
Diff: https://reviews.apache.org/r/66614/diff/1/
Testing
-------
Thanks,
Prasanth_J
