Package | Description |
---|---|
org.apache.storm.hive.common |
Modifier and Type | Method and Description |
---|---|
void |
HiveWriter.abort()
Aborts the current Txn and switches to next Txn.
|
void |
HiveWriter.flush(boolean rollToNext)
Commits the current Txn if totalRecordsPerTransaction > 0 .
|
void |
HiveWriter.flushAndClose()
Flush and Close current transactionBatch.
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.