public class TridentHBaseWindowingStoreTopology extends Object
Sample application of trident windowing which uses HBaseWindowsStoreFactory
’s store for storing tuples in window.
Constructor and Description |
---|
TridentHBaseWindowingStoreTopology() |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
buildTopology(WindowsStoreFactory windowsStore) |
static void |
main(String[] args) |
public static StormTopology buildTopology(WindowsStoreFactory windowsStore) throws Exception
Exception
Copyright © 2019 The Apache Software Foundation. All rights reserved.