Skip to content
Permalink
Browse files
Fixed bug with pull-based channel
Change-Id: If758f9e8d5c66c5badd819ad877d269bee4408c8
  • Loading branch information
sjaco002 committed Aug 10, 2018
1 parent 9d04999 commit d5aabe66d173e6e96e8e0db1f2598e87e96f2593
Showing 1 changed file with 8 additions and 1 deletion.
@@ -95,7 +95,14 @@ public NotifyBrokerRuntime(IHyracksTaskContext ctx, IScalarEvaluatorFactory brok
eval2 = channelExecutionEvalFactory.createScalarEvaluator(ctx);
this.entityId = activeJobId;
this.push = push;
recordPrinterFactory = new ARecordPrinterFactory((ARecordType) recordType).createPrinter();
if (push) {
//for push-based channel, the recordType is the result record type (records are sent directly)
recordPrinterFactory = new ARecordPrinterFactory((ARecordType) recordType).createPrinter();
} else {
//for pull-based channels, the recordType is a list of subscription ids
//the subscriptionIdListPrinterFactory is used instead
recordPrinterFactory = null;
}
subscriptionIdListPrinterFactory =
new AOrderedlistPrinterFactory(new AOrderedListType(BuiltinType.AUUID, null)).createPrinter();
executionTimeString = null;

0 comments on commit d5aabe6

Please sign in to comment.