• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java DataProcessor类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.arjuna.databroker.data.DataProcessor的典型用法代码示例。如果您正苦于以下问题:Java DataProcessor类的具体用法?Java DataProcessor怎么用?Java DataProcessor使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



DataProcessor类属于com.arjuna.databroker.data包,在下文中一共展示了DataProcessor类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getPropertyNames

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public <T extends DataFlowNode> List<String> getPropertyNames(Class<T> dataFlowNodeClass, Map<String, String> metaProperties)
    throws InvalidClassException, InvalidMetaPropertyException, MissingMetaPropertyException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
        {
            List<String> propertyNames = new LinkedList<String>();

            return propertyNames;
        }
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:19,代码来源:XSSFStreamSheetToCSVDataFlowNodeFactory.java


示例2: simplestConversion

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Test
public void simplestConversion()
{
    DataFlowNodeLifeCycleControl dataFlowNodeLifeCycleControl = new TestJEEDataFlowNodeLifeCycleControl();

    DummyDataSource dummyDataSource        = new DummyDataSource("Dummy Data Source", Collections.<String, String>emptyMap());
    DataProcessor   shapeFileDataProcessor = new ShapeFileConverterDataProcessor("ShapeFile Converter Data Processor", Collections.<String, String>emptyMap());
    DummyDataSink   dummyDataSink          = new DummyDataSink("Dummy Data Sink", Collections.<String, String>emptyMap());

    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSource, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), shapeFileDataProcessor, null);
    dataFlowNodeLifeCycleControl.completeCreationAndActivateDataFlowNode(UUID.randomUUID().toString(), dummyDataSink, null);

    ((ObservableDataProvider<File>) dummyDataSource.getDataProvider(File.class)).addDataConsumer((ObserverDataConsumer<File>) shapeFileDataProcessor.getDataConsumer(File.class));
    ((ObservableDataProvider<String>) shapeFileDataProcessor.getDataProvider(String.class)).addDataConsumer((ObserverDataConsumer<String>) dummyDataSink.getDataConsumer(String.class));

    File testFile = new File("/tmp/Gully_point/Gully_point.shp");
    dummyDataSource.sendData(testFile);

    dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSource);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(shapeFileDataProcessor);
    dataFlowNodeLifeCycleControl.removeDataFlowNode(dummyDataSink);

}
 
开发者ID:arjuna-technologies,项目名称:GeoAPI_DataBroker_PlugIn,代码行数:25,代码来源:ConverterTest.java


示例3: getClasses

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public List<Class<? extends DataFlowNode>> getClasses()
{
    List<Class<? extends DataFlowNode>> classes = new LinkedList<Class<? extends DataFlowNode>>();

    classes.add(DataProcessor.class);

    return classes;
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:10,代码来源:XSSFStreamSheetToCSVDataFlowNodeFactory.java


示例4: getMetaPropertyNames

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public <T extends DataFlowNode> List<String> getMetaPropertyNames(Class<T> dataFlowNodeClass)
    throws InvalidClassException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        List<String> metaPropertyNames = new LinkedList<String>();

        return metaPropertyNames;
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:14,代码来源:XSSFStreamSheetToCSVDataFlowNodeFactory.java


示例5: createDataFlowNode

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T extends DataFlowNode> T createDataFlowNode(String name, Class<T> dataFlowNodeClass, Map<String, String> metaProperties, Map<String, String> properties)
    throws InvalidClassException, InvalidNameException, InvalidMetaPropertyException, MissingMetaPropertyException, InvalidPropertyException, MissingPropertyException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
            return (T) new XSSFStreamSheetToCSVDataProcessor(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:16,代码来源:XSSFStreamSheetToCSVDataFlowNodeFactory.java


示例6: createDataFlowNode

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T extends DataFlowNode> T createDataFlowNode(String name, Class<T> dataFlowNodeClass, Map<String, String> metaProperties, Map<String, String> properties)
    throws InvalidClassException, InvalidNameException, InvalidMetaPropertyException, MissingMetaPropertyException, InvalidPropertyException, MissingPropertyException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
            return (T) new XSSFSheetToCSVDataProcessor(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:16,代码来源:XSSFSheetToCSVDataFlowNodeFactory.java


示例7: createDataFlowNode

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T extends DataFlowNode> T createDataFlowNode(String name, Class<T> dataFlowNodeClass, Map<String, String> metaProperties, Map<String, String> properties)
    throws InvalidClassException, InvalidNameException, InvalidMetaPropertyException, MissingMetaPropertyException, InvalidPropertyException, MissingPropertyException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
            return (T) new XSSFRowToJSONDataProcessor(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:Apache-POI_DataBroker_PlugIn,代码行数:16,代码来源:XSSFRowToJSONDataFlowNodeFactory.java


示例8: createDataFlowNode

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T extends DataFlowNode> T createDataFlowNode(String name, Class<T> dataFlowNodeClass, Map<String, String> metaProperties, Map<String, String> properties)
    throws InvalidClassException, InvalidNameException, InvalidMetaPropertyException, MissingMetaPropertyException, InvalidPropertyException, MissingPropertyException
{
    if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
            return (T) new FileReaderDataProcessor(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:FileSystem_DataBroker_PlugIn,代码行数:16,代码来源:FileReaderDataProcessorFactory.java


示例9: getClasses

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public List<Class<? extends DataFlowNode>> getClasses()
{
    List<Class<? extends DataFlowNode>> classes = new LinkedList<Class<? extends DataFlowNode>>();

    classes.add(DataSource.class);
    classes.add(DataProcessor.class);
    classes.add(DataSink.class);

    return classes;
}
 
开发者ID:arjuna-technologies,项目名称:WebService_DataBroker_PlugIn,代码行数:12,代码来源:SOAPWebServiceDataFlowNodeFactory.java


示例10: getMetaPropertyNames

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public <T extends DataFlowNode> List<String> getMetaPropertyNames(Class<T> dataFlowNodeClass)
    throws InvalidClassException
{
    if (dataFlowNodeClass.equals(DataSource.class) || dataFlowNodeClass.equals(DataProcessor.class) || dataFlowNodeClass.equals(DataSink.class))
        return Collections.emptyList();
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:WebService_DataBroker_PlugIn,代码行数:10,代码来源:SOAPWebServiceDataFlowNodeFactory.java


示例11: createDataFlowNode

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <T extends DataFlowNode> T createDataFlowNode(String name, Class<T> dataFlowNodeClass, Map<String, String> metaProperties, Map<String, String> properties)
    throws InvalidClassException, InvalidNameException, InvalidMetaPropertyException, MissingMetaPropertyException, InvalidPropertyException, MissingPropertyException
{
    if (dataFlowNodeClass.equals(DataSource.class))
    {
        if (metaProperties.isEmpty())
            return (T) new PullSOAPWebServiceDataSource(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else if (dataFlowNodeClass.equals(DataProcessor.class))
    {
        if (metaProperties.isEmpty())
            return (T) new Document2TextDataProcessor(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else if (dataFlowNodeClass.equals(DataSink.class))
    {
        if (metaProperties.isEmpty())
            return (T) new PushSOAPWebServiceDataSink(name, properties);
        else
            throw new InvalidMetaPropertyException("No metaproperties expected", null, null);
    }
    else
        throw new InvalidClassException("Unsupported class", dataFlowNodeClass.getName());
}
 
开发者ID:arjuna-technologies,项目名称:WebService_DataBroker_PlugIn,代码行数:30,代码来源:SOAPWebServiceDataFlowNodeFactory.java


示例12: getDataBrokerSummariesJSON

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@GET
@Produces(MediaType.APPLICATION_JSON)
public DataBrokerDTO getDataBrokerSummariesJSON()
{
    logger.log(Level.FINE, "DataBrokerWS.getDataBrokerSummariesJSON");

    if ((_dataFlowInventory != null) && (_dataFlowNodeFactoryInventory != null))
    {
        DataBrokerDTO dataBrokerDTO = new DataBrokerDTO();

        List<String> dataFlowNames = new LinkedList<String>();
        for (DataFlow dataFlow: _dataFlowInventory.getDataFlows())
            dataFlowNames.add(dataFlow.getName());
        dataBrokerDTO.setDataFlowNames(dataFlowNames);

        List<DataFlowNodeFactoryDTO> dataFlowNodeFactories = new LinkedList<DataFlowNodeFactoryDTO>();
        for (DataFlowNodeFactory dataFlowNodeFactory: _dataFlowNodeFactoryInventory.getDataFlowNodeFactorys())
        {
            List<Class<? extends DataFlowNode>> dataFlowNodeFactoryClasses = dataFlowNodeFactory.getClasses();

            Boolean dataSourceFactory    = dataFlowNodeFactoryClasses.contains(DataSource.class);
            Boolean dataSinkFactory      = dataFlowNodeFactoryClasses.contains(DataSink.class);;
            Boolean dataProcessorFactory = dataFlowNodeFactoryClasses.contains(DataProcessor.class);;
            Boolean dataServiceFactory   = dataFlowNodeFactoryClasses.contains(DataService.class);;
            Boolean dataStoreFactory     = dataFlowNodeFactoryClasses.contains(DataStore.class);;

            dataFlowNodeFactories.add(new DataFlowNodeFactoryDTO(dataFlowNodeFactory.getName(), dataFlowNodeFactory.getProperties(), dataSourceFactory, dataSinkFactory, dataProcessorFactory, dataServiceFactory, dataStoreFactory));
        }
        dataBrokerDTO.setDataFlowNodeFactories(dataFlowNodeFactories);

        return dataBrokerDTO;
    }
    else
        throw new WebApplicationException(HttpURLConnection.HTTP_INTERNAL_ERROR);
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:36,代码来源:DataBrokerWS.java


示例13: classToString

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
public static String classToString(Class<? extends DataFlowNode> dataFlowNodeClass)
{
    if (DataSource.class.isAssignableFrom(dataFlowNodeClass))
        return DATASOURCE_TYPE;
    else if (DataSink.class.isAssignableFrom(dataFlowNodeClass))
        return DATASINK_TYPE;
    else if (DataService.class.isAssignableFrom(dataFlowNodeClass))
        return DATASERVICE_TYPE;
    else if (DataStore.class.isAssignableFrom(dataFlowNodeClass))
        return DATASTORE_TYPE;
    else if (DataProcessor.class.isAssignableFrom(dataFlowNodeClass))
        return DATAPROCESSOR_TYPE;
    else
        return null;
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:16,代码来源:Utils.java


示例14: stringToClass

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
public static Class<? extends DataFlowNode> stringToClass(String dataFlowNodeClassName)
{
    if (DATASOURCE_TYPE.equals(dataFlowNodeClassName))
        return DataSource.class;
    else if (DATASINK_TYPE.equals(dataFlowNodeClassName))
        return DataSink.class;
    else if (DATASERVICE_TYPE.equals(dataFlowNodeClassName))
        return DataService.class;
    else if (DATASTORE_TYPE.equals(dataFlowNodeClassName))
        return DataStore.class;
    else if (DATAPROCESSOR_TYPE.equals(dataFlowNodeClassName))
        return DataProcessor.class;
    else
        return null;
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:16,代码来源:Utils.java


示例15: getSourceProviderClasses

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
private Collection<Class<?>> getSourceProviderClasses(DataFlowNode sourceDataFlowNode)
{
    if (sourceDataFlowNode instanceof DataSource)
        return ((DataSource) sourceDataFlowNode).getDataProviderDataClasses();
    else if (sourceDataFlowNode instanceof DataProcessor)
        return ((DataProcessor) sourceDataFlowNode).getDataProviderDataClasses();
    else if (sourceDataFlowNode instanceof DataService)
        return ((DataService) sourceDataFlowNode).getDataProviderDataClasses();
    else if (sourceDataFlowNode instanceof DataStore)
        return ((DataStore) sourceDataFlowNode).getDataProviderDataClasses();
    else
        return Collections.emptySet();
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:14,代码来源:XMLConfig.java


示例16: getSinkConsumerClasses

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
private Collection<Class<?>> getSinkConsumerClasses(DataFlowNode sinkDataFlowNode)
{
    if (sinkDataFlowNode instanceof DataProcessor)
        return ((DataProcessor) sinkDataFlowNode).getDataConsumerDataClasses();
    else if (sinkDataFlowNode instanceof DataService)
        return ((DataService) sinkDataFlowNode).getDataConsumerDataClasses();
    else if (sinkDataFlowNode instanceof DataStore)
        return ((DataStore) sinkDataFlowNode).getDataConsumerDataClasses();
    else if (sinkDataFlowNode instanceof DataSink)
        return ((DataSink) sinkDataFlowNode).getDataConsumerDataClasses();
    else
        return Collections.emptySet();
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:14,代码来源:XMLConfig.java


示例17: getSourceProvider

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
private <T> DataProvider<T> getSourceProvider(DataFlowNode sourceDataFlowNode, Class<T> dataClass)
{
    if (sourceDataFlowNode instanceof DataSource)
        return ((DataSource) sourceDataFlowNode).getDataProvider(dataClass);
    else if (sourceDataFlowNode instanceof DataProcessor)
        return ((DataProcessor) sourceDataFlowNode).getDataProvider(dataClass);
    else if (sourceDataFlowNode instanceof DataService)
        return ((DataService) sourceDataFlowNode).getDataProvider(dataClass);
    else if (sourceDataFlowNode instanceof DataStore)
        return ((DataStore) sourceDataFlowNode).getDataProvider(dataClass);
    else
        return null;
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:14,代码来源:XMLConfig.java


示例18: getSinkConsumer

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
private <T> DataConsumer<T> getSinkConsumer(DataFlowNode sinkDataFlowNode, Class<T> dataClass)
{
    if (sinkDataFlowNode instanceof DataProcessor)
        return ((DataProcessor) sinkDataFlowNode).getDataConsumer(dataClass);
    else if (sinkDataFlowNode instanceof DataService)
        return ((DataService) sinkDataFlowNode).getDataConsumer(dataClass);
    else if (sinkDataFlowNode instanceof DataStore)
        return ((DataStore) sinkDataFlowNode).getDataConsumer(dataClass);
    else if (sinkDataFlowNode instanceof DataSink)
        return ((DataSink) sinkDataFlowNode).getDataConsumer(dataClass);
    else
        return null;
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:14,代码来源:XMLConfig.java


示例19: getClasses

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@Override
public List<Class<? extends DataFlowNode>> getClasses()
{
    List<Class<? extends DataFlowNode>> classes = new LinkedList<Class<? extends DataFlowNode>>();
    
    classes.add(DataSource.class);
    classes.add(DataProcessor.class);
    classes.add(DataSink.class);
    classes.add(DataService.class);
    classes.add(DataStore.class);
    
    return classes;
}
 
开发者ID:arjuna-technologies,项目名称:Simple_DataBroker_PlugIn,代码行数:14,代码来源:SimpleDataFlowNodeFactory.java


示例20: getFactoryInfoJSON

import com.arjuna.databroker.data.DataProcessor; //导入依赖的package包/类
@GET
@Path("{dataflowid}/_factoryinfo")
@Produces(MediaType.APPLICATION_JSON)
public DataFlowNodeFactoryDTO getFactoryInfoJSON(@PathParam("dataflowid") String dataFlowId, @QueryParam("factoryname") String factoryName)
{
    logger.log(Level.FINE, "DataFlowWS.getFactoryInfoJSON");

    if (_dataFlowInventory != null)
    {
        if (dataFlowId != null)
        {
            DataFlow dataFlow = _dataFlowInventory.getDataFlow(dataFlowId);

            if ((dataFlow != null) && (dataFlow.getDataFlowNodeFactoryInventory() !=  null))
            {
                DataFlowNodeFactory dataFlowNodeFactory = dataFlow.getDataFlowNodeFactoryInventory().getDataFlowNodeFactory(factoryName);

                if (dataFlowNodeFactory != null)
                {
                    try
                    {
                        List<Class<? extends DataFlowNode>> dataFlowNodeFactoryClasses = dataFlowNodeFactory.getClasses();

                        Boolean dataSourceFactory    = dataFlowNodeFactoryClasses.contains(DataSource.class);
                        Boolean dataSinkFactory      = dataFlowNodeFactoryClasses.contains(DataSink.class);;
                        Boolean dataProcessorFactory = dataFlowNodeFactoryClasses.contains(DataProcessor.class);;
                        Boolean dataServiceFactory   = dataFlowNodeFactoryClasses.contains(DataService.class);;
                        Boolean dataStoreFactory     = dataFlowNodeFactoryClasses.contains(DataStore.class);;

                        return new DataFlowNodeFactoryDTO(dataFlowNodeFactory.getName(), dataFlowNodeFactory.getProperties(), dataSourceFactory, dataSinkFactory, dataProcessorFactory, dataServiceFactory, dataStoreFactory);
                    }
                    catch (Throwable throwable)
                    {
                        logger.log(Level.WARNING, "Problem while obtaining meta property names from data flow node factory: ", throwable);

                        throw new WebApplicationException(HttpURLConnection.HTTP_INTERNAL_ERROR);
                    }
                }
                else
                    throw new WebApplicationException(HttpURLConnection.HTTP_NOT_FOUND);
            }
            else
                throw new WebApplicationException(HttpURLConnection.HTTP_NOT_FOUND);
        }
        else
            throw new WebApplicationException(HttpURLConnection.HTTP_NOT_FOUND);
    }
    else
        throw new WebApplicationException(HttpURLConnection.HTTP_INTERNAL_ERROR);
}
 
开发者ID:RISBIC,项目名称:DataBroker,代码行数:51,代码来源:DataFlowWS.java



注:本文中的com.arjuna.databroker.data.DataProcessor类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java DeterministicHierarchy类代码示例发布时间:2022-05-22
下一篇:
Java MarshallerFactory类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap