----------------------------------------------------------- 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-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