Package org.apache.flume.node.nodemanager

Examples of org.apache.flume.node.nodemanager.DefaultLogicalNodeManager


         * @param data The data required to create the entity.
         * @return The FlumeAvroManager.
         */
        public FlumeEmbeddedManager createManager(final String name, final FactoryData data) {
            try {
                final DefaultLogicalNodeManager nodeManager = new DefaultLogicalNodeManager();
                final Properties props = createProperties(data.name, data.agents, data.properties, data.batchSize,
                    data.dataDir);
                final FlumeConfigurationBuilder builder = new FlumeConfigurationBuilder();
                final NodeConfiguration conf = builder.load(data.name, props, nodeManager);

View Full Code Here


         * @param data The data required to create the entity.
         * @return The FlumeAvroManager.
         */
        public FlumeEmbeddedManager createManager(String name, FactoryData data) {
            try {
                DefaultLogicalNodeManager nodeManager = new DefaultLogicalNodeManager();
                Properties props = createProperties(data.name, data.agents, data.properties, data.batchSize,
                    data.dataDir);
                FlumeConfigurationBuilder builder = new FlumeConfigurationBuilder();
                NodeConfiguration conf = builder.load(data.name, props, nodeManager);

View Full Code Here

TOP

Related Classes of org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.