[CONF] Apache Samza > SEP-30: Support Partial Updates in Table API

[Ajo Thomas (Confluence)]

Title: Message Title

There's 1 new edit on this page

SEP-30: Support Partial Updates in Table API Ajo Thomas edited this page Here's what changed: ... Code Block language java title Code Example final RemoteTableDescriptor outputTableDesc = new RemoteTableDescriptor<Integer, EnrichedPageView, EnrichedPageView>("enriched-page-view-table-1"); final Table<KV<Integer, Profile>> joinTable = appDesc. getTable(outputTableDesc); appDesc.getInputStream(isd) .map(pv -> new KV<>(pv.getMemberId(), pv)) .join(joinTable, new PageViewToProfileJoinFunction()) .map(m -> new KV(m.getMemberId(), UpdatePairUpdateMessage.of(m, m))) .sendUpdateTo(outputTable); ... Go to page history View page

Stop watching space • Manage notifications This message was sent by Atlassian Confluence 7.13.2