Package org.apache.flume.node

Examples of org.apache.flume.node.NodeConfiguration

173
174
175
176
177
178
179
180
181
182
183
            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);

                final FlumeNode node = new FlumeNode(nodeManager, nodeManager, conf);

                node.start();
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
            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);

                final FlumeNode node = new FlumeNode(nodeManager, nodeManager, conf);

                node.start();
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
    private final SourceFactory sourceFactory = new DefaultSourceFactory();
    private final SinkFactory sinkFactory = new DefaultSinkFactory();

    public NodeConfiguration load(final String name, final Properties props,
                                  final NodeConfigurationAware configurationAware) {
        final NodeConfiguration conf = new SimpleNodeConfiguration();
        FlumeConfiguration fconfig;
        try {
            fconfig = new FlumeConfiguration(props);
            final List<FlumeConfigurationError> errors = fconfig.getConfigurationErrors();
            if (errors.size() > 0) {
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
            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);

                final FlumeNode node = new FlumeNode(nodeManager, nodeManager, conf);

                node.start();
View Full Code Here
202
203
204
205
206
207
208
209
210
211
212
    try {
      reader = new BufferedReader(new FileReader(propertiesFile));
      Properties properties = new Properties();
      properties.load(reader);

      NodeConfiguration conf = new SimpleNodeConfiguration();
      FlumeConfiguration fconfig = new FlumeConfiguration(properties);
      AgentConfiguration agentConf = fconfig.getConfigurationFor(getNodeName());

      if (agentConf != null) {
        loadChannels(agentConf, conf);
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
      reader = new BufferedReader(new FileReader(propertiesFile));
      Properties properties = new Properties();
      properties.load(reader);
      // If there is an old configuration, shut it down.

      NodeConfiguration conf = new SimpleNodeConfiguration();
      FlumeConfiguration fconfig = new FlumeConfiguration(properties);
      AgentConfiguration agentConf = fconfig.getConfigurationFor(getNodeName());

      if (agentConf != null) {
        getConfigurationAware().stopAllComponents();
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
    try {
      reader = new BufferedReader(new FileReader(propertiesFile));
      Properties properties = new Properties();
      properties.load(reader);

      NodeConfiguration conf = new SimpleNodeConfiguration();
      FlumeConfiguration fconfig = new FlumeConfiguration(properties);
      AgentConfiguration agentConf = fconfig.getConfigurationFor(getNodeName());

      if (agentConf != null) {
        loadChannels(agentConf, conf);
View Full Code Here
180
181
182
183
184
185
186
187
188
189
190
            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);

                FlumeNode node = new FlumeNode(nodeManager, conf);

                node.start();
                LifecycleController.waitForOneOf(node, LifecycleState.START_OR_ERROR);
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
    private final ChannelFactory channelFactory = new DefaultChannelFactory();
    private final SourceFactory sourceFactory = new DefaultSourceFactory();
    private final SinkFactory sinkFactory = new DefaultSinkFactory();

    public NodeConfiguration load(String name, Properties props, NodeConfigurationAware configurationAware) {
        NodeConfiguration conf = new SimpleNodeConfiguration();
        FlumeConfiguration fconfig;
        try {
            fconfig = new FlumeConfiguration(props);
            List<FlumeConfigurationError> errors = fconfig.getConfigurationErrors();
            if (errors.size() > 0) {
View Full Code Here
174
175
176
177
178
179
180
181
182
183
184
            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);

                final FlumeNode node = new FlumeNode(nodeManager, nodeManager, conf);

                node.start();
View Full Code Here
TOP

Related Classes of org.apache.flume.node.NodeConfiguration

  • org.apache.flume.conf.properties.PropertiesFileConfigurationProvider
  • org.apache.logging.log4j.flume.appender.FlumeConfigurationBuilder
  • org.apache.logging.log4j.flume.appender.FlumeEmbeddedManager$FlumeManagerFactory
    • 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.