Java StreamingApplication类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getApexLauncher

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Override
protected Launcher<?> getApexLauncher() {
  return new Launcher<AppHandle>() {
    @Override
    public AppHandle launchApp(StreamingApplication application,
        Configuration configuration, AttributeMap launchParameters)
        throws org.apache.apex.api.Launcher.LauncherException {
      EmbeddedAppLauncher<?> embeddedLauncher = Launcher.getLauncher(LaunchMode.EMBEDDED);
      DAG dag = embeddedLauncher.getDAG();
      application.populateDAG(dag, new Configuration(false));
      String appName = dag.getValue(DAGContext.APPLICATION_NAME);
      Assert.assertEquals("DummyApp", appName);
      return new AppHandle() {
        @Override
        public boolean isFinished() {
          return true;
        }
        @Override
        public void shutdown(org.apache.apex.api.Launcher.ShutdownMode arg0) {
        }
      };
    }
  };
}

开发者ID:apache，项目名称:beam，代码行数:25，代码来源:ApexYarnLauncherTest.java

示例2: runLocal

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
/**
 * Run application in-process. Returns only once application completes.
 *
 * @param appConfig
 * @throws Exception
 */
public void runLocal(AppFactory appConfig) throws Exception
{
  propertiesBuilder.conf.setEnum(StreamingApplication.ENVIRONMENT, StreamingApplication.Environment.LOCAL);
  LogicalPlan lp = appConfig.createApp(propertiesBuilder);

  String libJarsCsv = lp.getAttributes().get(Context.DAGContext.LIBRARY_JARS);
  if (libJarsCsv != null && libJarsCsv.length() != 0) {
    String[] split = libJarsCsv.split(StramClient.LIB_JARS_SEP);
    for (String jarPath : split) {
      File file = new File(jarPath);
      URL url = file.toURI().toURL();
      launchDependencies.add(url);
    }
  }

  // local mode requires custom classes to be resolved through the context class loader
  loadDependencies();
  StramLocalCluster lc = new StramLocalCluster(lp);
  lc.run();
}

开发者ID:apache，项目名称:apex-core，代码行数:27，代码来源:StramAppLauncher.java

示例3: addFromProperties

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
/**
 * Read operator configurations from properties. The properties can be in any
 * random order, as long as they represent a consistent configuration in their
 * entirety.
 *
 * @param props
 * @param conf configuration for variable substitution and evaluation
 * @return Logical plan configuration.
 */
public LogicalPlanConfiguration addFromProperties(Properties props, Configuration conf)
{
  if (conf != null) {
    StramClientUtils.evalProperties(props, conf);
  }
  for (final String propertyName : props.stringPropertyNames()) {
    String propertyValue = props.getProperty(propertyName);
    this.properties.setProperty(propertyName, propertyValue);
    if (propertyName.startsWith(StreamingApplication.DT_PREFIX) ||
        propertyName.startsWith(StreamingApplication.APEX_PREFIX)) {
      String[] keyComps = propertyName.split(KEY_SEPARATOR_SPLIT_REGEX);
      parseStramPropertyTokens(keyComps, 1, propertyName, propertyValue, stramConf);
    }
  }
  return this;
}

开发者ID:apache，项目名称:apex-core，代码行数:26，代码来源:LogicalPlanConfiguration.java

示例4: testInjectionOfOperatorName

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testInjectionOfOperatorName() throws Exception
{
  StreamingApplication application = new StreamingApplication()
  {
    @Override
    public void populateDAG(DAG dag, Configuration conf)
    {
      dag.addOperator("input", new MockInputOperator());
    }
  };
  LocalMode lma = LocalMode.newInstance();
  lma.prepareDAG(application, new Configuration());
  LocalMode.Controller lc = lma.getController();
  lc.runAsync();
  latch.await();
  Assert.assertEquals("operator name", "input", operatorName);
  lc.shutdown();
}

开发者ID:apache，项目名称:apex-core，代码行数:20，代码来源:OperatorContextTest.java

示例5: testApp

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
public void testApp(StreamingApplication app) throws Exception
{
  try {
    LocalMode lma = LocalMode.newInstance();
    Configuration conf = new Configuration(false);
    lma.prepareDAG(app, conf);
    LocalMode.Controller lc = lma.getController();
    ((StramLocalCluster)lc).setExitCondition(new Callable<Boolean>()
    {
      @Override
      public Boolean call() throws Exception
      {
        return endApp;
      }
    });

    lc.run(200000); // runs for 20 seconds and quits if terminating condition not reached

    LOG.info("Control Tuples received {} expected {}", numControlTuples, controlIndex);
    Assert.assertTrue("Incorrect Control Tuples", numControlTuples == controlIndex);
  } catch (ConstraintViolationException e) {
    Assert.fail("constraint violations: " + e.getConstraintViolations());
  }
}

开发者ID:apache，项目名称:apex-core，代码行数:25，代码来源:CustomControlTupleTest.java

示例6: testAppLevelProperties

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
@SuppressWarnings("UnnecessaryBoxing")
public void testAppLevelProperties()
{
  String appName = "app1";
  Properties props = new Properties();
  props.put(StreamingApplication.APEX_PREFIX + "application." + appName + ".testprop1", "10");
  props.put(StreamingApplication.APEX_PREFIX + "application." + appName + ".prop.testprop2", "100");
  props.put(StreamingApplication.APEX_PREFIX + "application.*.prop.testprop3", "1000");
  props.put(StreamingApplication.APEX_PREFIX + "application." + appName + ".inncls.a", "10000");
  LogicalPlanConfiguration dagBuilder = new LogicalPlanConfiguration(new Configuration(false));
  dagBuilder.addFromProperties(props, null);

  LogicalPlan dag = new LogicalPlan();
  TestApplication app1Test = new TestApplication();

  dagBuilder.setApplicationConfiguration(dag, appName, app1Test);
  Assert.assertEquals("", Integer.valueOf(10), app1Test.getTestprop1());
  Assert.assertEquals("", Integer.valueOf(100), app1Test.getTestprop2());
  Assert.assertEquals("", Integer.valueOf(1000), app1Test.getTestprop3());
  Assert.assertEquals("", Integer.valueOf(10000), app1Test.getInncls().getA());
}

开发者ID:apache，项目名称:apex-core，代码行数:23，代码来源:LogicalPlanConfigurationTest.java

示例7: testSetOperatorProperties

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testSetOperatorProperties()
{

  Configuration conf = new Configuration(false);
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o1.prop.myStringProperty", "myStringPropertyValue");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.stringArrayField", "a,b,c");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty.key1", "key1Val");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty(key1.dot)", "key1dotVal");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty(key2.dot)", "key2dotVal");

  LogicalPlan dag = new LogicalPlan();
  GenericTestOperator o1 = dag.addOperator("o1", new GenericTestOperator());
  ValidationTestOperator o2 = dag.addOperator("o2", new ValidationTestOperator());

  LogicalPlanConfiguration pb = new LogicalPlanConfiguration(conf);

  pb.setOperatorProperties(dag, "testSetOperatorProperties");
  Assert.assertEquals("o1.myStringProperty", "myStringPropertyValue", o1.getMyStringProperty());
  Assert.assertArrayEquals("o2.stringArrayField", new String[] {"a", "b", "c"}, o2.getStringArrayField());

  Assert.assertEquals("o2.mapProperty.key1", "key1Val", o2.getMapProperty().get("key1"));
  Assert.assertEquals("o2.mapProperty(key1.dot)", "key1dotVal", o2.getMapProperty().get("key1.dot"));
  Assert.assertEquals("o2.mapProperty(key2.dot)", "key2dotVal", o2.getMapProperty().get("key2.dot"));

}

开发者ID:apache，项目名称:apex-core，代码行数:27，代码来源:LogicalPlanConfigurationTest.java

示例8: testAppNameAttribute

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testAppNameAttribute()
{
  StreamingApplication app = new AnnotatedApplication();
  Configuration conf = new Configuration(false);
  conf.addResource(StramClientUtils.DT_SITE_XML_FILE);

  LogicalPlanConfiguration builder = new LogicalPlanConfiguration(conf);

  Properties properties = new Properties();
  properties.put(StreamingApplication.APEX_PREFIX + "application.TestAliasApp.class", app.getClass().getName());

  builder.addFromProperties(properties, null);

  LogicalPlan dag = new LogicalPlan();
  String appPath = app.getClass().getName().replace(".", "/") + ".class";
  dag.setAttribute(com.datatorrent.api.Context.DAGContext.APPLICATION_NAME, "testApp");
  builder.prepareDAG(dag, app, appPath);

  Assert.assertEquals("Application name", "testApp", dag.getAttributes().get(com.datatorrent.api.Context.DAGContext.APPLICATION_NAME));
}

开发者ID:apache，项目名称:apex-core，代码行数:22，代码来源:LogicalPlanConfigurationTest.java

示例9: testAppAlias

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testAppAlias()
{
  StreamingApplication app = new AnnotatedApplication();
  Configuration conf = new Configuration(false);
  conf.addResource(StramClientUtils.DT_SITE_XML_FILE);

  LogicalPlanConfiguration builder = new LogicalPlanConfiguration(conf);

  Properties properties = new Properties();
  properties.put(StreamingApplication.APEX_PREFIX + "application.TestAliasApp.class", app.getClass().getName());

  builder.addFromProperties(properties, null);

  LogicalPlan dag = new LogicalPlan();
  String appPath = app.getClass().getName().replace(".", "/") + ".class";
  builder.prepareDAG(dag, app, appPath);

  Assert.assertEquals("Application name", "TestAliasApp", dag.getAttributes().get(com.datatorrent.api.Context.DAGContext.APPLICATION_NAME));
}

开发者ID:apache，项目名称:apex-core，代码行数:21，代码来源:LogicalPlanConfigurationTest.java

示例10: testJavaApplication

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testJavaApplication()
{
  Configuration conf = getConfiguration();
  StreamingAppFactory factory  = new StreamingAppFactory(Application.class.getName(), Application.class)
  {
    @Override
    public LogicalPlan createApp(LogicalPlanConfiguration planConfig)
    {
      Class<? extends StreamingApplication> c = StramUtils.classForName(Application.class.getName(), StreamingApplication.class);
      StreamingApplication app = StramUtils.newInstance(c);
      return super.createApp(app, planConfig);
    }
  };
  LogicalPlan dag = factory.createApp(new LogicalPlanConfiguration(conf));
  validateProperties(dag);
}

开发者ID:apache，项目名称:apex-core，代码行数:18，代码来源:DAGSetupPluginTests.java

示例11: testModuleProperties

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testModuleProperties()
{
  Configuration conf = new Configuration(false);
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o1.prop.myStringProperty", "myStringPropertyValue");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.stringArrayField", "a,b,c");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty.key1", "key1Val");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty(key1.dot)", "key1dotVal");
  conf.set(StreamingApplication.APEX_PREFIX + "operator.o2.prop.mapProperty(key2.dot)", "key2dotVal");

  LogicalPlan dag = new LogicalPlan();
  TestModules.GenericModule o1 = dag.addModule("o1", new TestModules.GenericModule());
  TestModules.ValidationTestModule o2 = dag.addModule("o2", new TestModules.ValidationTestModule());

  LogicalPlanConfiguration pb = new LogicalPlanConfiguration(conf);

  pb.setModuleProperties(dag, "testSetOperatorProperties");
  Assert.assertEquals("o1.myStringProperty", "myStringPropertyValue", o1.getMyStringProperty());
  Assert.assertArrayEquals("o2.stringArrayField", new String[]{"a", "b", "c"}, o2.getStringArrayField());

  Assert.assertEquals("o2.mapProperty.key1", "key1Val", o2.getMapProperty().get("key1"));
  Assert.assertEquals("o2.mapProperty(key1.dot)", "key1dotVal", o2.getMapProperty().get("key1.dot"));
  Assert.assertEquals("o2.mapProperty(key2.dot)", "key2dotVal", o2.getMapProperty().get("key2.dot"));

}

开发者ID:apache，项目名称:apex-core，代码行数:26，代码来源:TestModuleProperties.java

示例12: testLoadFromJson

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testLoadFromJson() throws Exception
{
  String resourcePath = "/testModuleTopology.json";
  InputStream is = this.getClass().getResourceAsStream(resourcePath);
  if (is == null) {
    throw new RuntimeException("Could not load " + resourcePath);
  }
  StringWriter writer = new StringWriter();

  IOUtils.copy(is, writer);
  JSONObject json = new JSONObject(writer.toString());

  Configuration conf = new Configuration(false);
  conf.set(StreamingApplication.APEX_PREFIX + "operator.operator3.prop.myStringProperty", "o3StringFromConf");

  LogicalPlanConfiguration planConf = new LogicalPlanConfiguration(conf);
  LogicalPlan dag = planConf.createFromJson(json, "testLoadFromJson");
  planConf.prepareDAG(dag, null, "testApplication");
  dag.validate();
  validateTopLevelOperators(dag);
  validateTopLevelStreams(dag);
  validatePublicMethods(dag);
}

开发者ID:apache，项目名称:apex-core，代码行数:25，代码来源:TestModuleExpansion.java

示例13: testApplication

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
public void testApplication(StreamingApplication streamingApplication) throws Exception
{
  try {
    LocalMode lma = LocalMode.newInstance();
    Configuration conf = new Configuration(false);
    conf.addResource(this.getClass().getResourceAsStream("/JdbcProperties.xml"));
    lma.prepareDAG(streamingApplication, conf);
    LocalMode.Controller lc = lma.getController();
    lc.setHeartbeatMonitoringEnabled(false);
    ((StramLocalCluster)lc).setExitCondition(new Callable<Boolean>()
    {
      @Override
      public Boolean call() throws Exception
      {
        return TupleCount == 10;
      }
    });
    lc.run(10000);// runs for 10 seconds and quits
    Assert.assertEquals("rows in db", TupleCount, getNumOfRowsinTable(TABLE_POJO_NAME));
  } catch (ConstraintViolationException e) {
    Assert.fail("constraint violations: " + e.getConstraintViolations());
  }

}

开发者ID:apache，项目名称:apex-malhar，代码行数:25，代码来源:JdbcInputOperatorApplicationTest.java

示例14: testApplication

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Test
public void testApplication() throws Exception {
  EmbeddedAppLauncher<?> launcher = Launcher.getLauncher(LaunchMode.EMBEDDED);
  Attribute.AttributeMap launchAttributes = new Attribute.AttributeMap.DefaultAttributeMap();
  //launchAttributes.put(EmbeddedAppLauncher.RUN_ASYNC, false);
  //launchAttributes.put(EmbeddedAppLauncher.HEARTBEAT_MONITORING, false);
  Configuration conf = new Configuration(false);
  conf.addResource(new Path(TEMPLATE_PROPERTIES_PATH));
  conf.addResource(new Path(PROPERTIES_PATH));
  //conf.addResource(this.getClass().getResourceAsStream("/META-INF/properties.xml"));
  conf.setBooleanIfUnset(TwitterStatsApp.IS_TWITTER_SAMPLE_INPUT, defaultTwitterInput);
  conf.setBooleanIfUnset(TwitterStatsApp.IS_WEBSOCKET_OUTPUT, defaultWebsocketOutput);

  StreamingApplication app = /*new TestApplication();*/ new TwitterStatsApp();
  AppHandle appHandle = launcher.launchApp(app, conf, launchAttributes);
  long timeoutMillis = System.currentTimeMillis() + Duration.standardMinutes(15).getMillis();
  while (!appHandle.isFinished() && System.currentTimeMillis() < timeoutMillis) {
    Thread.sleep(500);
  }
  appHandle.shutdown(ShutdownMode.KILL);
}

开发者ID:tweise，项目名称:apex-samples，代码行数:22，代码来源:TwitterStatsAppTest.java

示例15: launch

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
public static void launch(StreamingApplication app, String name, String libjars) throws Exception {
    Configuration conf = new Configuration(true);
//    conf.set("dt.loggers.level", "org.apache.*:DEBUG, com.datatorrent.*:DEBUG");
    conf.set("dt.dfsRootDirectory", System.getProperty("dt.dfsRootDirectory"));
    conf.set("fs.defaultFS", System.getProperty("fs.defaultFS"));
    conf.set("yarn.resourcemanager.address", System.getProperty("yarn.resourcemanager.address"));
    conf.addResource(new File(System.getProperty("dt.site.path")).toURI().toURL());

    if (libjars != null) {
      conf.set(StramAppLauncher.LIBJARS_CONF_KEY_NAME, libjars);
    }
    StramAppLauncher appLauncher = new StramAppLauncher(name, conf);
    appLauncher.loadDependencies();
    StreamingAppFactory appFactory = new StreamingAppFactory(app, name);
    appLauncher.launchApp(appFactory);
  }

开发者ID:apache，项目名称:incubator-samoa，代码行数:17，代码来源:ApexDoTask.java

示例16: main

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
public static void main(String[] args) throws Exception {
    StreamingApplication app = new LogLevelApplication();

    Configuration conf = new Configuration(false);
    conf.addResource(app.getClass().getResourceAsStream(
            "/META-INF/properties-LogLevelCount.xml"));

    LocalMode.runApp(app, conf, 140000);
}

开发者ID:bbende，项目名称:nifi-streaming-examples，代码行数:10，代码来源:LogLevelApplicationRunner.java

示例17: launchApp

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
public AppHandle launchApp(StreamingApplication app, Properties configProperties)
    throws IOException {

  List<File> jarsToShip = getYarnDeployDependencies();
  StringBuilder classpath = new StringBuilder();
  for (File path : jarsToShip) {
    if (path.isDirectory()) {
      File tmpJar = File.createTempFile("beam-runners-apex-", ".jar");
      createJar(path, tmpJar);
      tmpJar.deleteOnExit();
      path = tmpJar;
    }
    if (classpath.length() != 0) {
      classpath.append(':');
    }
    classpath.append(path.getAbsolutePath());
  }

  EmbeddedAppLauncher<?> embeddedLauncher = Launcher.getLauncher(LaunchMode.EMBEDDED);
  DAG dag = embeddedLauncher.getDAG();
  app.populateDAG(dag, new Configuration(false));

  Attribute.AttributeMap launchAttributes = new Attribute.AttributeMap.DefaultAttributeMap();
  launchAttributes.put(YarnAppLauncher.LIB_JARS, classpath.toString().replace(':', ','));
  LaunchParams lp = new LaunchParams(dag, launchAttributes, configProperties);
  lp.cmd = "hadoop " + ApexYarnLauncher.class.getName();
  HashMap<String, String> env = new HashMap<>();
  env.put("HADOOP_USER_CLASSPATH_FIRST", "1");
  env.put("HADOOP_CLASSPATH", classpath.toString());
  lp.env = env;
  return launchApp(lp);
}

开发者ID:apache，项目名称:beam，代码行数:33，代码来源:ApexYarnLauncher.java

示例18: runApp

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
/**
 * Shortcut to run an application with the modified configuration.
 *
 * @param app           - Application to be run
 * @param configuration - Configuration
 * @param runMillis     - The time after which the application will be shutdown; pass 0 to run indefinitely.
 */
public static void runApp(StreamingApplication app, Configuration configuration, int runMillis)
{
  EmbeddedAppLauncher launcher = newInstance();
  Attribute.AttributeMap launchAttributes = new Attribute.AttributeMap.DefaultAttributeMap();
  launchAttributes.put(RUN_MILLIS, (long)runMillis);
  launcher.launchApp(app, configuration, launchAttributes);
}

开发者ID:apache，项目名称:apex-core，代码行数:15，代码来源:EmbeddedAppLauncher.java

示例19: prepareDAG

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Override
public DAG prepareDAG(StreamingApplication app, Configuration conf) throws Exception
{
  if (app == null && conf == null) {
    throw new IllegalArgumentException("Require app or configuration to populate logical plan.");
  }
  if (conf == null) {
    conf = new Configuration(false);
  }
  LogicalPlanConfiguration lpc = new LogicalPlanConfiguration(conf);
  String appName = app != null ? app.getClass().getName() : "unknown";
  lpc.prepareDAG(lp, app, appName);
  return lp;
}

开发者ID:apache，项目名称:apex-core，代码行数:15，代码来源:EmbeddedAppLauncherImpl.java

示例20: launchApp

import com.datatorrent.api.StreamingApplication; //导入依赖的package包/类
@Override
public YarnAppHandleImpl launchApp(final StreamingApplication app, Configuration conf, Attribute.AttributeMap launchParameters) throws LauncherException
{
  if (launchParameters != null) {
    for (Map.Entry<Attribute<?>, Object> entry : launchParameters.entrySet()) {
      String property = propMapping.get(entry.getKey());
      if (property != null) {
        setConfiguration(conf, property, entry.getValue());
      }
    }
  }
  try {
    String name = app.getClass().getName();
    StramAppLauncher appLauncher = new StramAppLauncher(name, conf);
    appLauncher.loadDependencies();
    StreamingAppFactory appFactory = new StreamingAppFactory(name, app.getClass())
    {
      @Override
      public LogicalPlan createApp(LogicalPlanConfiguration planConfig)
      {
        return super.createApp(app, planConfig);
      }
    };
    ApplicationId appId = appLauncher.launchApp(appFactory);
    appLauncher.resetContextClassLoader();
    return new YarnAppHandleImpl(appId, conf);
  } catch (Exception ex) {
    throw new LauncherException(ex);
  }
}

开发者ID:apache，项目名称:apex-core，代码行数:31，代码来源:YarnAppLauncherImpl.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ContextCalculator类代码示例发布时间：2022-05-22

Java GibbsSampler类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18282|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9680|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8180|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8458|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9393|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8431|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8416|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java StreamingApplication类代码示例

示例1: getApexLauncher

示例2: runLocal

示例3: addFromProperties

示例4: testInjectionOfOperatorName

示例5: testApp

示例6: testAppLevelProperties

示例7: testSetOperatorProperties

示例8: testAppNameAttribute

示例9: testAppAlias

示例10: testJavaApplication

示例11: testModuleProperties

示例12: testLoadFromJson

示例13: testApplication

示例14: testApplication

示例15: launch

示例16: main

示例17: launchApp

示例18: runApp

示例19: prepareDAG

示例20: launchApp

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

tianli/matlab_offscreen: Matlab offscree

win7系统注册表编辑器打开的操作方法

これがマストドンだ！ 使い方からインスタ

芙蓉王（硬领航）多少钱一包？

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053

これがマストドンだ！使い方からインスタ