List of switchWriter() Examples

Examples of switchWriter()

org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

                // a crash could cause data loss.
                cfs.markObsolete(sstables, compactionType);
                return;
            }


            writer.switchWriter(createCompactionWriter(sstableDirectory, keysPerSSTable, minRepairedAt));
            while (iter.hasNext())
            {
                if (ci.isStopRequested())
                    throw new CompactionInterruptedException(ci.getCompactionInfo());

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

                if (writer.append(row) != null)
                {
                    totalKeysWritten++;
                    if (newSSTableSegmentThresholdReached(writer.currentWriter()))
                    {
                        writer.switchWriter(createCompactionWriter(sstableDirectory, keysPerSSTable, minRepairedAt));
                    }
                }
            }


            // don't replace old sstables yet, as we need to mark the compaction finished in the system table

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

        metrics.beginCompaction(ci);
        SSTableRewriter writer = new SSTableRewriter(cfs, new HashSet<>(ImmutableSet.of(sstable)), sstable.maxDataAge, OperationType.CLEANUP, false);


        try (CompactionController controller = new CompactionController(cfs, Collections.singleton(sstable), getDefaultGcBefore(cfs)))
        {
            writer.switchWriter(createWriter(cfs, compactionFileLocation, expectedBloomFilterSize, sstable.getSSTableMetadata().repairedAt, sstable));


            while (scanner.hasNext())
            {
                if (ci.isStopRequested())
                    throw new CompactionInterruptedException(ci.getCompactionInfo());

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

            List<ICompactionScanner> scanners = strategy.getScanners(Arrays.asList(sstable));


            try (CompactionController controller = new CompactionController(cfs, new HashSet<>(Collections.singleton(sstable)), CFMetaData.DEFAULT_GC_GRACE_SECONDS))
            {
                repairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, repairedAt, sstable));
                unRepairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, ActiveRepairService.UNREPAIRED_SSTABLE, sstable));


                CompactionIterable ci = new CompactionIterable(OperationType.ANTICOMPACTION, scanners, controller);


                try (CloseableIterator<AbstractCompactedRow> iter = ci.iterator())
                {

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

        metrics.beginCompaction(ci);
        SSTableRewriter writer = new SSTableRewriter(cfs, new HashSet<>(ImmutableSet.of(sstable)), sstable.maxDataAge, OperationType.CLEANUP, false);


        try (CompactionController controller = new CompactionController(cfs, Collections.singleton(sstable), getDefaultGcBefore(cfs)))
        {
            writer.switchWriter(createWriter(cfs, compactionFileLocation, expectedBloomFilterSize, sstable.getSSTableMetadata().repairedAt, sstable));


            while (scanner.hasNext())
            {
                if (ci.isStopRequested())
                    throw new CompactionInterruptedException(ci.getCompactionInfo());

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

            List<ICompactionScanner> scanners = strategy.getScanners(Arrays.asList(sstable));


            try (CompactionController controller = new CompactionController(cfs, new HashSet<>(Collections.singleton(sstable)), CFMetaData.DEFAULT_GC_GRACE_SECONDS))
            {
                repairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, repairedAt, sstable));
                unRepairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, ActiveRepairService.UNREPAIRED_SSTABLE, sstable));


                CompactionIterable ci = new CompactionIterable(OperationType.ANTICOMPACTION, scanners, controller);


                try (CloseableIterator<AbstractCompactedRow> iter = ci.iterator())
                {

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

        metrics.beginCompaction(ci);
        SSTableRewriter writer = new SSTableRewriter(cfs, new HashSet<>(ImmutableSet.of(sstable)), sstable.maxDataAge, OperationType.CLEANUP, false);


        try (CompactionController controller = new CompactionController(cfs, Collections.singleton(sstable), getDefaultGcBefore(cfs)))
        {
            writer.switchWriter(createWriter(cfs, compactionFileLocation, expectedBloomFilterSize, sstable.getSSTableMetadata().repairedAt, sstable));


            while (scanner.hasNext())
            {
                if (ci.isStopRequested())
                    throw new CompactionInterruptedException(ci.getCompactionInfo());

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

            List<ICompactionScanner> scanners = strategy.getScanners(Arrays.asList(sstable));


            try (CompactionController controller = new CompactionController(cfs, new HashSet<>(Collections.singleton(sstable)), CFMetaData.DEFAULT_GC_GRACE_SECONDS))
            {
                repairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, repairedAt, sstable));
                unRepairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, ActiveRepairService.UNREPAIRED_SSTABLE, sstable));


                CompactionIterable ci = new CompactionIterable(OperationType.ANTICOMPACTION, scanners, controller);


                try (CloseableIterator<AbstractCompactedRow> iter = ci.iterator())
                {

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

        metrics.beginCompaction(ci);
        SSTableRewriter writer = new SSTableRewriter(cfs, new HashSet<>(ImmutableSet.of(sstable)), sstable.maxDataAge, OperationType.CLEANUP, false);


        try (CompactionController controller = new CompactionController(cfs, Collections.singleton(sstable), getDefaultGcBefore(cfs)))
        {
            writer.switchWriter(createWriter(cfs, compactionFileLocation, expectedBloomFilterSize, sstable.getSSTableMetadata().repairedAt, sstable));


            while (scanner.hasNext())
            {
                if (ci.isStopRequested())
                    throw new CompactionInterruptedException(ci.getCompactionInfo());

View Full Code Here

Examples of org.apache.cassandra.io.sstable.SSTableRewriter.switchWriter()

            List<ICompactionScanner> scanners = strategy.getScanners(Arrays.asList(sstable));


            try (CompactionController controller = new CompactionController(cfs, new HashSet<>(Collections.singleton(sstable)), CFMetaData.DEFAULT_GC_GRACE_SECONDS))
            {
                repairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, repairedAt, sstable));
                unRepairedSSTableWriter.switchWriter(CompactionManager.createWriter(cfs, destination, expectedBloomFilterSize, ActiveRepairService.UNREPAIRED_SSTABLE, sstable));


                CompactionIterable ci = new CompactionIterable(OperationType.ANTICOMPACTION, scanners, controller);


                try (CloseableIterator<AbstractCompactedRow> iter = ci.iterator())
                {

View Full Code Here

0 1

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.