List of addPartition() Examples

Examples of addPartition()

com.facebook.giraph.hive.impl.input.InputInfo.addPartition()
Add a partition to read @param inputPartition Partition to add
com.linkedin.helix.model.Resource.addPartition()
edu.brown.catalog.ClusterConfiguration.addPartition()
org.apache.directory.server.core.DefaultDirectoryService.addPartition()
org.apache.directory.server.core.DirectoryService.addPartition()
org.apache.directory.server.core.api.DirectoryService.addPartition()
org.apache.hadoop.hive.ql.plan.AddPartitionDesc.addPartition()
org.apache.hcatalog.api.HCatClient.addPartition()
Adds the partition. @param partInfo An instance of HCatAddPartitionDesc. @throws HCatException
org.apache.helix.model.Resource.addPartition()
org.eclipse.persistence.descriptors.partitioning.RangePartitioningPolicy.addPartition()
PUBLIC: Add the range partition.
org.eclipse.persistence.descriptors.partitioning.ValuePartitioningPolicy.addPartition()
PUBLIC: Add the value partition.
org.wso2.carbon.apacheds.PartitionManager.addPartition()
Adds a new partition to current apacheds store. @param partitionInformation This contains necessary information to create a partition.Mainly it contains following information, 1. partitionId - The partition id. Usually this is tenant id. 2. realm domain - name of the partition. Usually domain name and partition DN are same. Ex :- o=example.com 3. partitionDN - Suffix used when creating the partition. Usually this is the domain name. DN: dc=example,dc=com 4. adminInfo - User information for the domain. @throws DirectoryServerException If an error occurs while adding the partition.
storm.kafka.trident.GlobalPartitionInformation.addPartition()

Examples of com.facebook.giraph.hive.impl.input.InputInfo.addPartition()


    InputInfo inputInfo = new InputInfo(tableSchema, columnIds);


    if (table.getPartitionKeysSize() == 0) {
      // table without partitions
      inputInfo.addPartition(new InputPartition(table));
    } else {
      // table with partitions, find matches to user filter.
      List<Partition> partitions = null;
      try {
        partitions = client.get_partitions_by_filter(dbName, tableName,

View Full Code Here

Examples of com.linkedin.helix.model.Resource.addPartition()

    if (!resourceMap.containsKey(resourceName))
    {
      resourceMap.put(resourceName, new Resource(resourceName));
    }
    Resource resource = resourceMap.get(resourceName);
    resource.addPartition(partition);


  }
}

View Full Code Here

Examples of edu.brown.catalog.ClusterConfiguration.addPartition()

        // (2) Update catalog to include target cluster configuration
        ClusterConfiguration cc = new ClusterConfiguration();
        // Update cc with a bunch of hosts/sites/partitions
        for (int site = 0, currentPartition = 0; site < m_siteCount; ++site) {
            for (int partition = 0; partition < m_partitionPerSite; ++partition, ++currentPartition) {
                cc.addPartition("localhost", site, currentPartition);
            }
        }
        tmpCatalog = FixCatalog.cloneCatalog(tmpCatalog, cc);
        
        // (3) Write updated catalog back out to jar file

View Full Code Here

Examples of org.apache.directory.server.core.DefaultDirectoryService.addPartition()

            service.getChangeLog().setEnabled( true );
            
            Partition foo = new JdbmPartition();
            foo.setId( "foo" );
            foo.setSuffix( "dc=foo,dc=com" );
            service.addPartition( foo );
            
            Partition bar = new JdbmPartition();
            bar.setId( "bar" );
            bar.setSuffix( "dc=bar,dc=com" );
            service.addPartition( bar );

View Full Code Here

Examples of org.apache.directory.server.core.DefaultDirectoryService.addPartition()

            service.addPartition( foo );
            
            Partition bar = new JdbmPartition();
            bar.setId( "bar" );
            bar.setSuffix( "dc=bar,dc=com" );
            service.addPartition( bar );
            
            return service;
        }
    }

View Full Code Here

Examples of org.apache.directory.server.core.DefaultDirectoryService.addPartition()

    return partition;
  }


  private static DefaultDirectoryService createDirectory( Partition rootPartition, File workDir ) throws Exception {
    DefaultDirectoryService directory = new DefaultDirectoryService();
    directory.addPartition( rootPartition );
    directory.setExitVmOnShutdown( false );
    directory.setShutdownHookEnabled( true );
    directory.getChangeLog().setEnabled( false );
    directory.setDenormalizeOpAttrsEnabled( true );
    directory.setWorkingDirectory( initWorkDir( null ) );

View Full Code Here

Examples of org.apache.directory.server.core.DirectoryService.addPartition()

            }


            partition.setSchemaManager( service.getSchemaManager() );


            // Inject the partition into the DirectoryService
            service.addPartition( partition );


            // Last, process the context entry
            ContextEntry contextEntry = createPartition.contextEntry();


            if ( contextEntry != null )

View Full Code Here

Examples of org.apache.directory.server.core.DirectoryService.addPartition()

        // The schema partition
        SchemaPartition schemaPartition = new SchemaPartition( schemaManager );
        schemaPartition.setWrappedPartition( schemaLdifPartition );
        directoryService.setSchemaPartition( schemaPartition );


        directoryService.addPartition( configPartition );


        // Store the default directories
        directoryService.setInstanceLayout( instanceLayout );


        directoryService.startup();

View Full Code Here

Examples of org.apache.directory.server.core.DirectoryService.addPartition()

            }


            partition.setSchemaManager( service.getSchemaManager() );


            // Inject the partition into the DirectoryService
            service.addPartition( partition );


            // Last, process the context entry
            ContextEntry contextEntry = createPartition.contextEntry();


            if ( contextEntry != null )

View Full Code Here

Examples of org.apache.directory.server.core.DirectoryService.addPartition()

            }


            partition.setSchemaManager( service.getSchemaManager() );


            // Inject the partition into the DirectoryService
            service.addPartition( partition );


            // Last, process the context entry
            ContextEntry contextEntry = createPartition.contextEntry();


            if ( contextEntry != null )

View Full Code Here

0 1 2 3 4 5

TOP

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.