List of snapshot() Examples

Examples of snapshot()

akka.persistence.SnapshotOffer.snapshot()
ariba.ui.meta.core.Context.snapshot()
com.espertech.esper.epl.named.NamedWindowTailViewInstance.snapshot()
Returns a snapshot of window contents, thread-safely @param filter filters if any @return window contents
com.facebook.presto.jdbc.internal.guava.cache.AbstractCache.SimpleStatsCounter.snapshot()
com.google.common.cache.AbstractCache.SimpleStatsCounter.snapshot()
com.google.common.cache.AbstractCache.StatsCounter.snapshot()
com.google_voltpatches.common.cache.AbstractCache.SimpleStatsCounter.snapshot()
com.hp.hpl.jena.util.MonitorGraph.snapshot()
Compute the differences between the current monitored graph and the last snapshot. The changes will also be forwarded to any listeners. Then take a new snapshot. @param additions a place in which the set of newly added triples should be noted, can be null @param deletions a place in which the set of newly deleted triples should be noted, can be null
com.hp.hpl.jena.util.MonitorModel.snapshot()
Compute the differences between the current monitored graph and the last snapshot. The changes will also be forwarded to any listeners. Then take a new snapshot. @param additions a place in which the set of newly added statements should be noted, can be null @param deletions a place in which the set of newly deleted statements should be noted, can be null
com.mongodb.DBCursor.snapshot()
Use snapshot mode for the query. Snapshot mode assures no duplicates are returned, or objects missed, which were present at both the start and end of the query's execution (if an object is new during the query, or deleted during the query, it may or may not be returned, even with snapshot mode). Note that short query responses (less than 1MB) are always effectively snapshotted. Currently, snapshot mode may not be used with sorting or explicit hints. @return same DBCursor for chaining operations
com.opengamma.engine.marketdata.MarketDataProvider.snapshot()
Obtains access to a snapshot of market data. @param marketDataSpec describes the market data to obtain, not null @return the snapshot, not null
com.opengamma.livedata.LiveDataClient.snapshot()
Asks for a snapshot from the server, waiting for a reply.
This method waits for a reply from the server before returning. Always contacts the server, even if there is an active subscription to this market data. @param user the user credentials, checked to ennsure user is authorized to access the data, not null @param requestedSpecification what market data you want to subscribe to, and in which standardized format you want the server to give it to you @param timeout the timeout in milliseconds. If the timeout is non-positive, this method will not wait at all, so null will be returned. @return the snapshot @throws OpenGammaRuntimeException if timeout was reached without reply from server
com.sun.jini.reliableLog.ReliableLog.snapshot()
Records the client-defined current snapshot by invoking the client supplied snapshot callback, and then empties the log of incremental updates. @throws LogException if the snapshot callback throws an exception @throws IOException if any other I/O error occurs
com.webobjects.eocontrol.EOEnterpriseObject.snapshot()
er.corebusinesslogic.ERCMailMessage.snapshot()
er.erxtest.model.Employee.snapshot()
io.airlift.stats.Distribution.snapshot()
javafx.scene.Node.snapshot()
javafx.scene.canvas.Canvas.snapshot()
javafx.scene.text.Text.snapshot()
jersey.repackaged.com.google.common.cache.AbstractCache.SimpleStatsCounter.snapshot()
net.grinder.statistics.StatisticsSet.snapshot()
org.apache.aurora.scheduler.storage.log.LogManager.StreamManager.snapshot()
org.apache.cassandra.db.ColumnFamilyStore.snapshot()
Take a snap shot of this columnfamily store. @param snapshotName the name of the associated with the snapshot
org.apache.cassandra.db.Keyspace.snapshot()
Take a snapshot of the specific column family, or the entire set of column families if columnFamily is null with a given timestamp @param snapshotName the tag associated with the name of the snapshot. This value may not be null @param columnFamilyName the column family to snapshot or all on null @throws IOException if the column family doesn't exist
org.apache.cassandra.db.Table.snapshot()
Take a snapshot of the entire set of column families with a given timestamp. @param clientSuppliedName the tag associated with the name of the snapshot. Thisvalue can be null.
org.apache.hadoop.hbase.client.Admin.snapshot()
Take a snapshot for the given table. If the table is enabled, a FLUSH-type snapshot will be taken. If the table is disabled, an offline snapshot is taken. Snapshots are considered unique based on the name of the snapshot. Attempts to take a snapshot with the same name (even a different type or with different parameters) will fail with a {@link org.apache.hadoop.hbase.snapshot.SnapshotCreationException} indicating the duplicate naming.Snapshot names follow the same naming constraints as tables in HBase. See {@link org.apache.hadoop.hbase.TableName#isLegalFullyQualifiedTableName(byte[])}. @param snapshotName name of the snapshot to be created @param tableName name of the table for which snapshot is created @throws IOException if a remote or network exception occurs @throws org.apache.hadoop.hbase.snapshot.SnapshotCreationException if snapshot creation failed @throws IllegalArgumentException if the snapshot request is formatted incorrectly
org.apache.hadoop.hbase.client.HBaseAdmin.snapshot()
Create a timestamp consistent snapshot for the given table.
Snapshots are considered unique based on the name of the snapshot. Attempts to take a snapshot with the same name (even a different type or with different parameters) will fail with a {@link SnapshotCreationException} indicating the duplicate naming.
Snapshot names follow the same naming constraints as tables in HBase. See {@link HTableDescriptor#isLegalTableName(byte[])}. @param snapshotName name of the snapshot to be created @param tableName name of the table for which snapshot is created @throws IOException if a remote or network exception occurs @throws SnapshotCreationException if snapshot creation failed @throws IllegalArgumentException if the snapshot request is formatted incorrectly
org.apache.hadoop.hbase.ipc.HMasterInterface.snapshot()
org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()
Take a snapshot of the most recent commit to the index. You must call release() to free this snapshot. Note that while the snapshot is held, the files it references will not be deleted, which will consume additional disk space in your index. If you take a snapshot at a particularly bad time (say just before you call optimize()) then in the worst case this could consume an extra 1X of your total index size, until you release the snapshot.
org.elasticsearch.action.admin.indices.status.IndicesStatusRequest.snapshot()
Should the status include recovery information. Defaults to false.
org.elasticsearch.index.gateway.IndexShardGatewayService.snapshot()
Snapshots the given shard into the gateway.
org.elasticsearch.index.snapshots.IndexShardSnapshotAndRestoreService.snapshot()
Creates shard snapshot @param snapshotId snapshot id @param snapshotStatus snapshot status
org.rocksdb.ReadOptions.snapshot()
Returns the currently assigned Snapshot instance. @return the Snapshot assigned to this instance. If no Snapshotis assigned null.
org.springframework.data.mongodb.repository.Meta.snapshot()
sun.rmi.log.ReliableLog.snapshot()
Records this value as the current snapshot by invoking the client supplied "snapshot" callback and then empties the log. @param value the object representing the new snapshot @exception IOException If an exception occurred during thesnapshot callback or if other I/O error has occurred during the snapshot process

Examples of org.apache.hadoop.hbase.ipc.HMasterInterface.snapshot()

    Mockito.when(mockConnection.getConfiguration()).thenReturn(conf);
    Mockito.when(mockConnection.getMaster()).thenReturn(mockMaster);
    // set the max wait time for the snapshot to complete
    Mockito
        .when(
          mockMaster.snapshot(
            Mockito.any(HSnapshotDescription.class))).thenReturn((long)maxWaitTime);


    // first five times, we return false, last we get success
    Mockito.when(
      mockMaster.isSnapshotDone(

View Full Code Here

Examples of org.apache.hadoop.hbase.ipc.HMasterInterface.snapshot()

    // mock the master connection
    HMasterInterface master = Mockito.mock(HMasterInterface.class);
    Mockito.when(mockConnection.getMaster()).thenReturn(master);


    Mockito.when(
      master.snapshot(Mockito.any(HSnapshotDescription.class))).thenReturn((long)0);
    Mockito.when(
      master.isSnapshotDone(
        Mockito.any(HSnapshotDescription.class))).thenReturn(true);


      // make sure that we can use valid names

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

    writer.setMaxBufferedDocs(2);
    Document doc = new Document();
    doc.add(new Field("content", "aaa", Field.Store.YES, Field.Index.ANALYZED, Field.TermVector.WITH_POSITIONS_OFFSETS));
    for(int i=0;i<7;i++)
      writer.addDocument(doc);
    IndexCommit cp = (IndexCommit) dp.snapshot();
    copyFiles(dir, cp);
    writer.close();
    copyFiles(dir, cp);
    
    writer = new IndexWriter(dir, true, new StandardAnalyzer(), dp);

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

    writer.addDocument(new Document());
    writer.commit();
    
    String s1 = "s1";
    String s2 = "s2";
    IndexCommit ic1 = sdp.snapshot(s1);
    IndexCommit ic2 = sdp.snapshot(s2);
    assertTrue(ic1 == ic2); // should be the same instance
    
    // create another commit
    writer.addDocument(new Document());

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

    writer.commit();
    
    String s1 = "s1";
    String s2 = "s2";
    IndexCommit ic1 = sdp.snapshot(s1);
    IndexCommit ic2 = sdp.snapshot(s2);
    assertTrue(ic1 == ic2); // should be the same instance
    
    // create another commit
    writer.addDocument(new Document());
    writer.commit();

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

    Directory dir = newDirectory();
    SnapshotDeletionPolicy sdp = getDeletionPolicy();
    IndexWriter writer = new IndexWriter(dir, getConfig(random, sdp));
    writer.addDocument(new Document());
    writer.commit();
    IndexCommit ic = sdp.snapshot("s1");


    // create another commit, not snapshotted.
    writer.addDocument(new Document());
    writer.close();

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

        @Override
        public void run() {
          try {
            writer.addDocument(new Document());
            writer.commit();
            sdp.snapshot(getName());
          } catch (Exception e) {
            throw new RuntimeException(e);
          }
        }
      };

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

        Thread commitThread =  new Thread(new Runnable() {
            @Override
            public void run() {
              try {
                iw.commit();
                IndexCommit ic = sdp.snapshot();
                for (String name : ic.getFileNames()) {
                  //distribute, and backup
                  //System.out.println(names);
                  assertTrue(dir.fileExists(name));
                }

View Full Code Here

Examples of org.apache.lucene.index.SnapshotDeletionPolicy.snapshot()

          name, _tableContext.getTable(), _shardContext.getShard());
      throw new IOException("A Snapshot already exists with the same name [" + name + "] on " +
        "["+_tableContext.getTable()+"/"+_shardContext.getShard()+"].");
    }
    _writer.commit();
    IndexCommit indexCommit = snapshotter.snapshot(name);
    
    /*
     * Persist the snapshots info into a tmp file under the snapshots sub-folder
     * and once writing is finished, close the writer.
     * Now rename the tmp file to an actual snapshots file.

View Full Code Here

Examples of org.elasticsearch.action.admin.indices.status.IndicesStatusRequest.snapshot()

    @Override public void handleRequest(final RestRequest request, final RestChannel channel) {
        IndicesStatusRequest indicesStatusRequest = new IndicesStatusRequest(splitIndices(request.param("index")));
        // we just send back a response, no need to fork a listener
        indicesStatusRequest.listenerThreaded(false);
        indicesStatusRequest.recovery(request.paramAsBoolean("recovery", indicesStatusRequest.recovery()));
        indicesStatusRequest.snapshot(request.paramAsBoolean("snapshot", indicesStatusRequest.snapshot()));
        BroadcastOperationThreading operationThreading = BroadcastOperationThreading.fromString(request.param("operation_threading"), BroadcastOperationThreading.SINGLE_THREAD);
        if (operationThreading == BroadcastOperationThreading.NO_THREADS) {
            // since we don't spawn, don't allow no_threads, but change it to a single thread
            operationThreading = BroadcastOperationThreading.SINGLE_THREAD;
        }

View Full Code Here

0 1 2 3 4 5 6 7

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.