I hereby claim:
- I am devinrsmith on github.
- I am thundza (https://keybase.io/thundza) on keybase.
- I have a public key ASAlSaR_IWYFj5wrQStDmkdbokcE2XRud33tT8jBjO-npgo
To claim this, I am signing this object:
import java.io.File; | |
import java.io.IOException; | |
import java.nio.ByteBuffer; | |
import java.nio.ByteOrder; | |
import java.nio.file.Files; | |
import org.lmdbjava.Cursor; | |
import org.lmdbjava.Dbi; | |
import org.lmdbjava.DbiFlags; | |
import org.lmdbjava.Env; | |
import org.lmdbjava.Txn; |
import com.fasterxml.jackson.annotation.JsonProperty; | |
import com.fasterxml.jackson.core.JsonProcessingException; | |
import com.fasterxml.jackson.databind.ObjectMapper; | |
import java.io.IOException; | |
import java.nio.charset.Charset; | |
import java.nio.charset.StandardCharsets; | |
import org.junit.Test; | |
import static org.assertj.core.api.Assertions.assertThat; | |
import static org.assertj.core.api.Assertions.fail; |
import com.googlecode.cqengine.ConcurrentIndexedCollection; | |
import com.googlecode.cqengine.IndexedCollection; | |
import com.googlecode.cqengine.attribute.SimpleAttribute; | |
import com.googlecode.cqengine.index.compound.CompoundIndex; | |
import com.googlecode.cqengine.query.option.QueryOptions; | |
import com.googlecode.cqengine.resultset.ResultSet; | |
import static com.googlecode.cqengine.query.QueryFactory.and; | |
import static com.googlecode.cqengine.query.QueryFactory.equal; | |
import static com.googlecode.cqengine.query.QueryFactory.in; |
I hereby claim:
To claim this, I am signing this object:
import org.apache.kafka.clients.producer.KafkaProducer; | |
import org.apache.kafka.clients.producer.Producer; | |
import org.apache.kafka.clients.producer.ProducerRecord; | |
import java.util.Properties; | |
import java.util.concurrent.ExecutionException; | |
/** | |
* Created by dsmith on 8/5/15. | |
*/ |
import java.util.Spliterator; | |
import java.util.function.Function; | |
import java.util.stream.Collectors; | |
import java.util.stream.Stream; | |
import java.util.stream.StreamSupport; | |
/** | |
* Created by dsmith on 7/21/15. | |
*/ | |
public class SpliteratorTest { |
import java.io.IOException; | |
import java.net.HttpURLConnection; | |
import java.net.URI; | |
/** | |
* Created by dsmith on 4/8/15. | |
*/ | |
public class UrlTest { | |
public static void main(String[] args) throws IOException { | |
final HttpURLConnection urlConnection = (HttpURLConnection) |
import com.google.common.base.Suppliers; | |
import com.google.common.collect.AbstractIterator; | |
import com.google.common.collect.Iterators; | |
import java.util.*; | |
import java.util.function.Consumer; | |
import java.util.function.Supplier; | |
/** | |
* Created by dsmith on 3/19/15. |
import java.util.function.Supplier; | |
/** | |
* Created by dsmith on 2/16/15. | |
* | |
* https://en.wikipedia.org/wiki/Double-checked_locking | |
* | |
*/ | |
public class DoubleCheckedSupplier<T> implements Supplier<T> { | |
public static <T> Supplier<T> of(Supplier<T> supplier) { |
Log file created at: 2015/01/14 16:22:07 | |
Running on machine: xxx | |
Binary: Built with gc go1.3.1 for linux/amd64 | |
Log line format: [IWEF]mmdd hh:mm:ss threadid file:line] msg | |
I0114 16:22:07 00001 file_util.go:20] Folder /data Permission: -rwxr-xr-x | |
I0114 16:22:07 00001 volume.go:108] loading file /data/images_3.idx readonly false | |
I0114 16:22:08 00001 store.go:225] data file /data/images_3.dat, replicaPlacement=001 v=2 size=582434260 ttl= | |
I0114 16:22:08 00001 volume.go:108] loading file /data/images_6.idx readonly false | |
I0114 16:22:08 00001 store.go:225] data file /data/images_6.dat, replicaPlacement=001 v=2 size=568452399 ttl= | |
I0114 16:22:08 00001 store.go:232] Store started on dir: /data with 2 volumes max 16 |