Re: Review Request 66614: HIVE-19210: Create separate module for streaming ingest

2018-04-13 Thread j . prasanth . j

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

2018-04-13 Thread j . prasanth . j

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