Examples of addSource()

Examples of cascading.flow.FlowDef.addSource()

129
130
131
132
133
134
135
136
137
138
139
        Tap status = platform.makeTap(platform.makeBinaryScheme(StatusDatum.FIELDS), statusPath, SinkMode.REPLACE);
       
        // Finally we can run it.
        FlowDef flowDef = new FlowDef();
        flowDef.setName("testHeadersInStatus");
        flowDef.addSource(pipe, in);
        flowDef.addTailSink(fetchPipe.getStatusTailPipe(), status);
        flowDef.addTailSink(fetchPipe.getContentTailPipe(), new NullSinkTap());
       
        FlowConnector flowConnector = platform.makeFlowConnector();
        Flow flow = flowConnector.connect(flowDef);
View Full Code Here

Examples of cascading.lingual.platform.LingualFlowFactory.addSource()

153
154
155
156
157
158
159
160
161
162
163
    for( Ref head : branch.heads.keySet() )
      {
      TableDef tableDefFor = getTableDefFor( platformBroker, head );
      String[] jarPath = ClassLoaderUtil.getJarPaths( getPlatformBroker(), tableDefFor );

      flowFactory.addSource( head.name, tableDefFor, jarPath );
      }

    FlowListener flowListener = null;

    if( branch.tailTableDef != null )
View Full Code Here

Examples of com.android.builder.resources.AssetSet.addSource()

590
591
592
593
594
595
596
597
598
599
600
        for (int n = mFlatLibraries.size() - 1 ; n >= 0 ; n--) {
            AndroidDependency dependency = mFlatLibraries.get(n);
            File assetFolder = dependency.getAssetsFolder();
            if (assetFolder != null) {
                AssetSet assetSet = new AssetSet(dependency.getFolder().getName());
                assetSet.addSource(assetFolder);
                assetSets.add(assetSet);
            }
        }

        Set<File> mainResDirs = mDefaultSourceProvider.getAssetsDirectories();
View Full Code Here

Examples of com.android.builder.resources.ResourceSet.addSource()

535
536
537
538
539
540
541
542
543
544
545
        for (int n = mFlatLibraries.size() - 1 ; n >= 0 ; n--) {
            AndroidDependency dependency = mFlatLibraries.get(n);
            File resFolder = dependency.getResFolder();
            if (resFolder != null) {
                ResourceSet resourceSet = new ResourceSet(dependency.getFolder().getName());
                resourceSet.addSource(resFolder);
                resourceSets.add(resourceSet);
            }
        }

        Set<File> mainResDirs = mDefaultSourceProvider.getResourcesDirectories();
View Full Code Here

Examples of com.android.ide.common.res2.AssetSet.addSource()

1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
            for (int n = mFlatLibraries.size() - 1 ; n >= 0 ; n--) {
                LibraryDependency dependency = mFlatLibraries.get(n);
                File assetFolder = dependency.getAssetsFolder();
                if (assetFolder.isDirectory()) {
                    AssetSet assetSet = new AssetSet(dependency.getFolder().getName());
                    assetSet.addSource(assetFolder);
                    assetSets.add(assetSet);
                }
            }
        }
View Full Code Here

Examples of com.android.ide.common.res2.ResourceSet.addSource()

929
930
931
932
933
934
935
936
937
938
939
            for (int n = mFlatLibraries.size() - 1 ; n >= 0 ; n--) {
                LibraryDependency dependency = mFlatLibraries.get(n);
                File resFolder = dependency.getResFolder();
                if (resFolder.isDirectory()) {
                    ResourceSet resourceSet = new ResourceSet(dependency.getFolder().getName());
                    resourceSet.addSource(resFolder);
                    resourceSets.add(resourceSet);
                }
            }
        }
View Full Code Here

Examples of com.jme3.shader.Shader.addSource()

410
411
412
413
414
415
416
417
418
419
420
                String vertSource = (String) loadAsset(new AssetKey(vertName));
                String fragSource = (String) loadAsset(new AssetKey(fragName));

                shader = new Shader();
                shader.initialize();
                shader.addSource(Shader.ShaderType.Vertex, vertName, vertSource, key.getDefines().getCompiled(), key.getVertexShaderLanguage());
                shader.addSource(Shader.ShaderType.Fragment, fragName, fragSource, key.getDefines().getCompiled(), key.getFragmentShaderLanguage());
            }

            cache.addToCache(key, shader);
        }
View Full Code Here

Examples of com.lightcrafts.mediax.jai.ParameterBlockJAI.addSource()

375
376
377
378
379
380
381
382
383
384
385
            new ParameterBlockJAI("Mosaic",
                                  RenderedRegistryMode.MODE_NAME);

        int numSources = sources.length;
        for(int i = 0; i < numSources; i++) {
            pb.addSource(sources[i]);
        }

        pb.setParameter("mosaicType", mosaicType);
        pb.setParameter("sourceAlpha", sourceAlpha);
        pb.setParameter("sourceROI", sourceROI);
View Full Code Here

Examples of com.linkedin.databus2.relay.config.PhysicalSourceConfig.addSource()

914
915
916
917
918
919
920
921
922
923
924
      LogicalSourceConfig lc = new LogicalSourceConfig();
      lc.setId(sourceIds[i]);
      lc.setName(sourceNames[i]);
      lc.setPartitionFunction(partitionFunction);
      lc.setUri(pPartName + "." + sourceNames[i]); // this format is expected by GG
      pc.addSource(lc);
    }


    return pc.build();
  }
View Full Code Here

Examples of com.linkedin.databus2.relay.config.PhysicalSourceConfig.addSource()

273
274
275
276
277
278
279
280
281
282
283
      LogicalSourceConfig c = new LogicalSourceConfig();
      c.setId(manager.getSrcId(srcName));
      c.setName(srcName);
      c.setUri(dbName + "." + dbObjectName);
      c.setPartitionFunction("constant:1");
      config.addSource(c);
    }

    DatabusRelaySourcesInFiles relaySourcesInFiles = new DatabusRelaySourcesInFiles(outputDir);
    relaySourcesInFiles.add(dbName, config);
    boolean success = relaySourcesInFiles.save();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.