本文整理了Java中org.kitesdk.morphline.base.Notifications.notifyRollbackTransaction()
方法的一些代码示例,展示了Notifications.notifyRollbackTransaction()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Notifications.notifyRollbackTransaction()
方法的具体详情如下:
包路径:org.kitesdk.morphline.base.Notifications
类名称:Notifications
方法名:notifyRollbackTransaction
[英]Notify the given command that a transaction has been rolled back.
[中]通知给定命令事务已回滚。
代码示例来源:origin: apache/flume
@Override
public void rollbackTransaction() {
Notifications.notifyRollbackTransaction(morphline);
}
代码示例来源:origin: org.apache.flume.flume-ng-sinks/flume-ng-morphline-solr-sink
@Override
public void rollbackTransaction() {
Notifications.notifyRollbackTransaction(morphline);
}
代码示例来源:origin: cloudera-labs/envelope
public static List<Record> executePipeline(Pipeline pipeline, Record inputRecord, boolean errorOnEmpty) {
Command morphline = pipeline.getMorphline();
try {
LOG.trace("Input Record: {}", inputRecord);
// Process the Record
Notifications.notifyStartSession(morphline);
boolean success = morphline.process(inputRecord);
Notifications.notifyCommitTransaction(morphline);
if (!success) {
throw new MorphlineRuntimeException("Morphline failed to process incoming Record: " + inputRecord);
}
// Collect the output
List<Record> outputRecords = pipeline.getCollector().getRecords();
if (errorOnEmpty && !outputRecords.iterator().hasNext()) {
throw new MorphlineRuntimeException("Morphline did not produce output Record(s)");
}
LOG.trace("Output Record(s): {}", outputRecords);
return outputRecords;
} catch (RuntimeException e) {
Notifications.notifyRollbackTransaction(morphline);
// TODO : Review exception handling
LOG.warn("Morphline failed to execute properly on incoming Record: " + inputRecord, e);
throw e;
}
}
代码示例来源:origin: kite-sdk/kite
@Test
public void testNotifications() throws Exception {
morphline = createMorphline("test-morphlines/pipeWithTwoBasicCommands");
Notifications.notifyBeginTransaction(morphline);
Notifications.notifyStartSession(morphline);
Notifications.notifyCommitTransaction(morphline);
Notifications.notifyRollbackTransaction(morphline);
}
代码示例来源:origin: kite-sdk/kite
/** Usage: java ... <morphline.conf> <dataFile1> ... <dataFileN> */
public static void main(String[] args) throws IOException {
// compile morphline.conf file on the fly
File morphlineFile = new File(args[0]);
String morphlineId = null;
MorphlineContext morphlineContext = new MorphlineContext.Builder().build();
Command morphline = new Compiler().compile(morphlineFile, morphlineId, morphlineContext, null);
// process each input data file
Notifications.notifyBeginTransaction(morphline);
try {
for (int i = 1; i < args.length; i++) {
InputStream in = new BufferedInputStream(new FileInputStream(new File(args[i])));
Record record = new Record();
record.put(Fields.ATTACHMENT_BODY, in);
Notifications.notifyStartSession(morphline);
boolean success = morphline.process(record);
if (!success) {
System.out.println("Morphline failed to process record: " + record);
}
in.close();
}
Notifications.notifyCommitTransaction(morphline);
} catch (RuntimeException e) {
Notifications.notifyRollbackTransaction(morphline);
morphlineContext.getExceptionHandler().handleException(e, null);
}
Notifications.notifyShutdown(morphline);
}
}
代码示例来源:origin: kite-sdk/kite
Notifications.notifyRollbackTransaction(morphline);
Notifications.notifyShutdown(morphline);
代码示例来源:origin: kite-sdk/kite
@Test
public void testLoadSolrBasic() throws Exception {
//System.setProperty("ENV_SOLR_HOME", testSolrHome + File.separator + "collection1");
morphline = createMorphline("test-morphlines" + File.separator + "loadSolrBasic");
//System.clearProperty("ENV_SOLR_HOME");
Record record = new Record();
record.put(Fields.ID, "id0");
record.put("first_name", "Nadja"); // will be sanitized
startSession();
Notifications.notifyBeginTransaction(morphline);
assertTrue(morphline.process(record));
assertEquals(1, collector.getNumStartEvents());
Notifications.notifyCommitTransaction(morphline);
Record expected = new Record();
expected.put(Fields.ID, "id0");
assertEquals(Arrays.asList(expected), collector.getRecords());
assertEquals(1, queryResultSetSize("*:*"));
Notifications.notifyRollbackTransaction(morphline);
Notifications.notifyShutdown(morphline);
}
代码示例来源:origin: kite-sdk/kite
assertFalse(iter.hasNext());
Notifications.notifyRollbackTransaction(morphline);
Notifications.notifyShutdown(morphline);
代码示例来源:origin: kite-sdk/kite
assertFalse(iter.hasNext());
Notifications.notifyRollbackTransaction(morphline);
Notifications.notifyShutdown(morphline);
代码示例来源:origin: kite-sdk/kite
assertNull(docs.get(1).getFirstValue(LoadSolrBuilder.LOAD_SOLR_DELETE_BY_QUERY));
Notifications.notifyRollbackTransaction(morphline);
Notifications.notifyShutdown(morphline);
内容来源于网络,如有侵权,请联系作者删除!